from multiprocessing import Queueq = Queue(5) # 产生一个最多能够存放五个数据的队列
q.put(1) # 往队列中存放数据,# 如果存放的数据个数大于队列最大存储个数,程序会阻塞 print(q.full) # 判断队列是否饱和
    q.get() # 取数据,get一次就取一个
q.get_nowait() # 在队列有数据的情况下,与get取值相同# 在队列没有数据的情况下,取值直接报错print(q.empty()) # 判断队列是否为空,在并发情况下,判断不准确print(q.get()) # 如果队列为空,get就会在原地等待队列中有数据过来

from multiprocessing import Queue, Processdef producer(q):q.put('hello world')def consumer(q):print(q.get())if __name__ =='__main__':q.Queue() # 生成一个队列对象p1 = Process(target=producer,args=(q,))c1 = Process(target=consumer,args=(q,))p1.start()c1.start()

from multiprocessing import Process,Queue,JoinableQueue
import time
import randomdef produce(name,food,q):for i in range(5):data = '%s 做了 %s%s' % (name,food,i)time.sleep(random.randint(1,3))print(data)q.put(data) # 将生产的数据放入队列中def consumer(name,q):while True:data:str = q.get() if data is None:breaktime.sleep(random.randint(1,3))data = data.replace('了', '的')print('%s 吃了 %s' % (name, data))if __name__ == '__main__':q = Queue() # 生成一个队列对象p1 = Process(target=produce,args=('egon', '包子', q,))p2 = Process(target=produce,args=('tank', '小笼', q,))c1 = Process(target=consumer,args=('owen', q,))c2 = Process(target=consumer,args=('jason', q,))p1.start()p2.start()c1.start()c2.start()p1.join() # 等待生产者生产完所有的数据p2.join() # 等待生产者生产完所有的数据# 在生产者生产完数据之后,往队列里面放一个提示性的消息,告诉消费者已经没有数据,你走吧,不要等了
    #q.put(None)#q.put(None)　　　　

from multiprocessing import Process, JoinableQueue
import time
import randomdef produce(name, food, q):for i in range(5):data = '%s 做了 %s%s' % (name, food, i)time.sleep(random.randint(1, 3))print(data)q.put(data)  # 将生产的数据放入队列中def consumer(name, q):while True:data: str = q.get()if data is None: breaktime.sleep(random.randint(1, 3))data = data.replace('了', '的')print('%s 吃了 %s' % (name, data))q.task_done()  # 告诉你的队列，你已经将数据取出并且处理完毕if __name__ == '__main__':q = JoinableQueue()  # 生成一个队列对象p1 = Process(target=produce, args=('egon', '包子', q,))p2 = Process(target=produce, args=('tank', '小笼', q,))c1 = Process(target=consumer, args=('owen', q,))c2 = Process(target=consumer, args=('jason', q,))p1.start()p2.start()c1.daemon = Truec2.daemon = Truec1.start()c2.start()# 等待生产者生产完所有的数据
    p1.join()p2.join()q.join()  # 等待队列中数据全部取出

from threading import Thread
import timedef task(name):print('%s is running' % name)time.sleep(1)print('%s is running' % name)t = Thread(target=task,args=('egon',))
t.start()
print('主')

from threading import Thread
import timeclass MyThread(Thread):def __init__(self,name):super().__init__() # 重写功能,以防父类功能缺少执行self.name = namedef run(self):print('%s is running' % self.name)time.sleep(1)print('%s is running' % self.name)t = MyThread('egon')
t.start()
print('主')

from threading import Threadx = 100def task():global xx = 1t = Thread(target=task)
t.start()
t.join()
print(x)

from threading import Thread, Lock
import timex = 100
mutex = Lock()def task():global xmutex.acquire()temp = xtime.sleep(0.1)x = temp - 1mutex.release()t_list = []
for i in range(100):t = Thread(target=task)t_list.append(t)t.start()for i in t_list:i.join()print(x)

from threading import Thread, active_count, current_thread
import os, timedef task():print('%s is running' % current_thread().name,os.getpid())time.sleep(1)print('%s is done' % os.getpid())t = Thread(target=task)
t.start()
print(active_count())
print('主', os.getpid(),current_thread().name)

from threading import Thread
import timedef task():print('is running')time.sleep(2)print('is over')t = Thread(target=task)
t.daemon = True
t.start()
print('主')