В настоящее время у меня есть скрипт, который читает строки из файла, сохраняет его в значение, а затем отправляет несколько запросов с этим значением. Я попытался создать многопоточность, чтобы несколько задач завершили работу, чтобы быстрее пройти через текстовый файл. Проблема в том, что потоки / задачи абсолютно одинаковы. Например, задача 1 читает строку 1, задача 2 - строку 2, задача 3 - строку 3 и т. Д. Я хотел бы, чтобы задание 1 читало строку 1, задание 2 - чтение строки 2. (как только задание 1 завершается / завершается), задание 1 будет считывать строку 3 и т. Д.
Вот то, что я имею до сих пор. ..
class myThread (threading.Thread):
def __init__(self, threadID, name, counter):
threading.Thread.__init__(self)
self.threadID = threadID
self.name = name
self.counter = counter
f = open("gmails.txt", "r")
for line in f:
field = line.split(':')
gmail = field[0]
time = datetime.now()
**DO SOMETHING
def print_time(threadName, delay, counter):
while counter:
if exitFlag:
threadName.exit()
time.sleep(delay)
print ("%s: %s" % (threadName, time.ctime(time.time())))
counter -= 1
# Create new threads
thread1 = myThread(1, "Task-1", 1)
thread2 = myThread(2, "Task-2", 2)
thread3 = myThread(3, "Task-3", 3)
# Start new Threads
thread1.start()
thread2.start()
thread3.start()
thread1.join()
thread2.join()
thread3.join()