Многопоточность Python / задачи для цикла - PullRequest
0 голосов
/ 04 ноября 2019

В настоящее время у меня есть скрипт, который читает строки из файла, сохраняет его в значение, а затем отправляет несколько запросов с этим значением. Я попытался создать многопоточность, чтобы несколько задач завершили работу, чтобы быстрее пройти через текстовый файл. Проблема в том, что потоки / задачи абсолютно одинаковы. Например, задача 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()
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...