Queue线程安全队列

 1 import threading,time
 2 from queue import Queue
 3 
 4 def set_value(q):
 5     index = 0
 6     while True:
 7         q.put(index)
 8         index += 1
 9         time.sleep(3)
10 
11 def get_value(q):
12     while True:
13         print (q.get())
14 
15 def main():
16     q = Queue(4)
17     t1 = threading.Thread(target=set_value, args=[q])
18     t2 = threading.Thread(target=get_value, args=[q])
19 
20     t1.start()
21     t2.start()
22 
23 if __name__ == ‘__main__‘:
24     main()