从一个文件中读取同一行的线程

Question

我正在尝试在 python 中使用线程，我对线程很陌生。我希望线程从同一个文件中读取随机行，但所有线程都读取同一行。所以我试图阅读的文件的所有行都是 email:pass:another_line 格式的。我希望用多个线程从同一个文件中读取不同的行，但它用多个线程读取同一行。 因此，例如 1 个线程将返回 line1，第二个线程将返回 line2 但它的随机行。

import random
import threading

def email_pass_token():
    global email, pass2, token

    file = open("testing/pokens.csv").read().splitlines()
    acc_str = random.choice(file)

    num_lines = sum(1 for _ in file)
    print(num_lines)

    email = ":".join(acc_str.split(":", 1)[:1])

    pass2 = ":".join(acc_str.split(":", 2)[:2][1:])

    token = ":".join(acc_str.split(":", 3)[:3][2:])
email_pass_token()

def gen_acc():
    print(email, pass2, token)

threads = []
num_thread = input("Threads: ")
num_thread = int(num_thread)
for i in range(num_thread):
    t = threading.Thread(target=gen_acc)
    threads.append(t)
    t.start()

文件示例：

tqqe435ihwbta@oncemail.co.kr:#354946345e696$e30*417:another_line1
tkbzw543vwxzn@oncemail.co.kr:2e5548c543709!8@305-8(:another_line2
jcgeau43yphr@oncemail.co.kr:41c!954=7543cc^1#48fd_$*b5:another_line3
bqajs543qlqys@oncemail.co.kr:1f@e54d78^feb54355&6$50:another_line4
tqqeihw54bta@oncemail.co.kr:#3946345e696$e30*417:another_line5
tkbzwvwx543zn@oncemail.co.kr:2e58c5437709!8@305-8(:another_line6
jcgeauy453phr@oncemail.co.kr:41c!9=7543cc^1#48fd_$*b5:another_line7
bqajsqlq54ys@oncemail.co.kr:1f@ed78^feb53455&6$50:another_line8

Answer 1

您没有运行在线程中选择行的功能。您正在做的是在仅打印三个变量email、pass2 和token 的线程中运行gen_acc。您选择行的代码位于email_pass_token，它只被调用一次。

Answer 2

这是您可以做到的一种方法。请注意，如果 密码 包含冒号，这将不起作用。另外，我已经硬编码了线程数，但你明白了。

import random
from concurrent.futures import ThreadPoolExecutor

FILENAME = 'testing/pokens.csv'
NTHREADS = 5

def myfunc():
    with open(FILENAME) as infile:
        lines = infile.readlines()
        line = random.choice(lines).strip()
        tokens = line.split(':')
        return ' '.join(tokens)

def main():
    with ThreadPoolExecutor() as executor:
        futures = []
        printable = set()
        for _ in range(NTHREADS):
            future = executor.submit(myfunc)
            futures.append(future)
        for future in futures:
            printable.add(future.result())
        for p in printable:
            print(p)

if __name__ == '__main__':
    main()