例1:
import threading
import time
class mythread(threading.Thread):
def __init__(self):
threading.Thread.__init__(self)
def run(self):
global x
lock.acquire()
for i in range(3):
x = x+i
time.sleep(2)
print(x)
lock.release()
lock = threading.Lock()
t1=[]
for i in range(10):
t=mythread()
t1.append(t)
x=0
for i in t1:
i.start()
输出结果:
3
6
9
12
15
18
21
24
27
30
例2:多线程编程从指定范围内计算出素数的个数
import threading
import time
def prime(x):
if x<2:return False
if x in (2,3):return True
if x%2==0:return False
for i in range(3,int(x**0.5)+1,2):
if x%i==0:return False
return True
def worker(p):
global c
while True:
try:
x=next(p)
except:
break
else:
if prime(x):
lock.acquire()
c=c+1
lock.release()
c=0
lock=threading.Lock()
numbers=iter(range(100))
tList=[]
for i in range(10):
t=threading.Thread(target=worker,args=(numbers,))
tList.append(t)
start=time.time()
for t in tList:t.start()
for t in tList:t.join()
print(time.time()-start)
print("count=",c)
输出结果为:
0.008002758026123047
count= 25
问题:第一个例子中,10个线程启动后,每个线程依次输出一个数字,数字之间相差3,10个线程最后输出了10个数字。而第二个例子中,也是10个线程,10个线程启动后,每个线程会取一个数判断是不是素数,为什么10个线程总共可以取100个数?每个线程又是如何运行的呢?取到的数如果是素数,c值加1,如果不是素数呢?就结束这个线程进行下一个线程吗?