最近尝试使用多线程用于以后的需求,我在做小测试的时候尝试加锁。结果加之前运行还是预期的,加了以后死循环了,是啥原因?求解~
//Mythread.py
import time
import threading
class TestThread(threading.Thread):
def init(self,testlist,name):
threading.Thread.__init__(self)
self.testlist = testlist
self.name = name
def run(self):
threadlock.acquire()
self.t = done(self.testlist)
for j in self.testlist:
time.sleep(1)
print(self.name + '|' + time.asctime(time.localtime(time.time())) + ':The number is ' + next(self.t))
threadlock.release()
def done(alist):
for i in alist:
yield str(i)
if i < 1599:
yield str(i+2)
else:
yield 'EOF'
threadlock = threading.Lock()
thread1 = TestThread(range(3200),'thread-1')
thread2 = TestThread(range(3200),'thread-2')
thread3 = TestThread(range(3200),'thread-3')
thread1.start()
time.sleep(0.33)
thread2.start()
time.sleep(0.33)
thread3.start()
thread1.join()
thread2.join()
thread3.join()
print('OK')