浅谈互斥锁与进程间的通信(举例说明)

from multiprocessing import Process,Lock
import os
import time
def work(mutex):
    mutex.acquire()
    print('task[%s] 上厕所'%os.getpid())
    time.sleep(3)
    print('task[%s] 上完厕所'%os.getpid())
    mutex.release()
if __name__ == '__main__':
    mutex = Lock()
    p1 = Process(target=work,args=(mutex,))
    p2 = Process(target=work,args=(mutex,))
    p3 = Process(target=work,args=(mutex,))
    p1.start()
    p2.start()
    p3.start()
    p1.join()
    p2.join()
    p3.join()
    print('主')

import json
import time
from multiprocessing import Process,Lock


def search(name):
    time.sleep(1)
    dic = json.load(open("db.txt", "r", encoding="utf-8"))
    print("<%s> 查看到的剩余票数 %s" % (name, dic["count"]))


def get(name):
    time.sleep(0.1)
    dic = json.load(open("db.txt", "r", encoding="utf-8"))
    if dic["count"] > 0:
        dic["count"] -= 1
        time.sleep(0.1)
        json.dump(dic, open("db.txt", "w", encoding="utf-8"))
        print("<%s> 购票成功" % name)
    else:
        print("<%s> 购票失败，已经无剩余票" % name)


def task(name, mutex):
    search(name)

    mutex.acquire()
    get(name)
    mutex.release()


if __name__ == "__main__":
    mutex = Lock()
    for i in range(100):
        p = Process(target=task, args=("路人%s" % i, mutex))
        p.start()

q.put方法用以插入数据到队列中，put方法还有两个可选参数：
blocked和timeout。如果blocked为True（默认值），并且timeout为正值，该方法会阻塞timeout指定的时间，
直到该队列有剩余的空间。如果超时，会抛出Queue.Full异常。如果blocked为False，
但该Queue已满，会立即抛出Queue.Full异常。
q.get方法可以从队列读取并且删除一个元素。
同样，get方法有两个可选参数：blocked和timeout。如果blocked为True（默认值），并且timeout为正值，
那么在等待时间内没有取到任何元素，会抛出Queue.Empty异常。如果blocked为False，有两种情况存在，
如果Queue有一个值可用，则立即返回该值，否则，如果队列为空，则立即抛出Queue.Empty异常.
   
q.get_nowait():同q.get(False)
q.put_nowait():同q.put(False)
  
q.empty():调用此方法时q为空则返回True，该结果不可靠，比如在返回True的过程中，
如果队列中又加入了项目。
q.full()：调用此方法时q已满则返回True，该结果不可靠，比如在返回True的过程中，
如果队列中的项目被取走。
q.qsize():返回队列中目前项目的正确数量，结果也不可靠，理由同q.empty()和q.full()一样

# 1.可以往队列里放任意类型的
# 2.先进先出
from multiprocessing import Process,Queue
q= Queue(3)
q.put('first')  #默认block=True
q.put('second')
q.put('third')

print(q.get())
print(q.get())
print(q.get())

from multiprocessing import Process,Queue
import os
import time
import random
#首先得有生产者和消费者
# 生产者制造包子
'''这种用 q.put(None)放进去一个None的方法虽然解决了问题
但是如果有多个生产者多个消费者，或许框里面没有包子了但是
还有其他的食物呢，你就已经显示空着，这样也可以解决，就是不完美，
还可以用到JoinableQueue去解决'''
def producter(q):
    for i in range(10):
        time.sleep(2) #生产包子得有个过程，就先让睡一会
        res = '包子%s'%i #生产了这么多的包子
        q.put(res)  #把生产出来的包子放进框里面去
        print('\033[44m%s制造了%s\033[0m'%(os.getpid(),res))
    q.put(None) #只有生产者才知道什么时候就生产完了（放一个None进去说明此时已经生产完了）
# 消费者吃包子
def consumer(q):
    while True:#假如消费者不断的吃
        res = q.get()
        if res is None:break #如果吃的时候框里面已经空了，就直接break了
        time.sleep(random.randint(1,3))
        print('\033[41m%s吃了%s\033[0m' % (os.getpid(),res))
if __name__ == '__main__':
    q = Queue()
    p1 = Process(target=producter,args=(q,))
    p2 = Process(target=consumer,args=(q,))
    p1.start()
    p2.start()
    p1.join()
    p2.join()  #等待执行完上面的进程，在去执行主
    print('主')

from multiprocessing import Process,JoinableQueue
import os
import time
import random
#首先得有生产者和消费者
# 消费者吃包子
def consumer(q):
    while True:
        res = q.get()
        time.sleep(random.randint(1,3))
        print('\033[41m%s吃了%s\033[0m' % (os.getpid(),res))
        q.task_done() #任务结束了（消费者告诉生产者，我已经吧东西取走了）
def product_baozi(q):
    for i in range(5):
        time.sleep(2)
        res = '包子%s' % i
        q.put(res)
        print('\033[44m%s制造了%s\033[0m' % (os.getpid(), res))
    q.join() #不用put(None) 了，在等q被取完。（如果数据没有被取完，生产者就不会结束掉）
def product_gutou(q):
    for i in range(5):
        time.sleep(2)
        res = '骨头%s' % i
        q.put(res)
        print('\033[44m%s制造了%s\033[0m' % (os.getpid(), res))
    q.join()
def product_doujiang(q):
    for i in range(5):
        time.sleep(2)
        res = '豆浆%s' % i
        q.put(res)
        print('\033[44m%s制造了%s\033[0m' % (os.getpid(), res))
    q.join()

if __name__ == '__main__':
    q = JoinableQueue()
    # 生产者们：厨师们
    p1 = Process(target=product_baozi,args=(q,))
    p2 = Process(target=product_doujiang,args=(q,))
    p3 = Process(target=product_gutou,args=(q,))

    #消费者们：吃货们
    p4 = Process(target=consumer,args=(q,))
    p5 = Process(target=consumer,args=(q,))
    p4.daemon = True
    p5.daemon = True
    # p1.start()
    # p2.start()
    # p3.start()
    # p4.start()
    # p5.start()
    li = [p1,p2,p3,p4,p5]
    for i in li:
        i.start()
    p1.join()
    p2.join()
    p3.join()
    print('主')