我目前有一个脚本,该脚本从文件中读取行,将其保存为一个值,然后使用该值发送一些请求。我尝试进行线程化,以使多个任务完成作业以更快地通过txt文件。问题是线程/任务完全相同。例如,任务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()