 python3学习手册manager_func(cond, name): cond.acquire() cond.wait() # manager要先运行,等待操作员的请求 print(name + ": 变更方案有问题,先不变更,先改方案") cond.notify() # 发消息给Operator,唤醒一个挂起的线程 cond.wait() # 等待Operator的回复 print(name 收到,现在变更") def manager_func(event, name): event.wait() # manager要先运行,等待操作员的请求 print(name + ": 变更方案有问题,先不变更,先改方案") time.sleep(random.randint(1, 3)) event.set() # 发回复给Operator,唤醒一个挂起的线程 event ★多进程之线程队列Queue 使 用 mul�processing.JoinableQueue() 方 法 创 建 一 个 队 列 , 它 与 queue.Queue的区别在于,它是多进程安全的,不用担心它的互斥和死 锁问题。 比如,有一个仓库用来存放商品,假如最多只能放5个商品,A不停的 放,B不停的取,A和B的放取速度不一致,就可以用队列来做 import multiprocessing import queue0 码力 | 213 页 | 3.53 MB | 1 年前3 python3学习手册manager_func(cond, name): cond.acquire() cond.wait() # manager要先运行,等待操作员的请求 print(name + ": 变更方案有问题,先不变更,先改方案") cond.notify() # 发消息给Operator,唤醒一个挂起的线程 cond.wait() # 等待Operator的回复 print(name 收到,现在变更") def manager_func(event, name): event.wait() # manager要先运行,等待操作员的请求 print(name + ": 变更方案有问题,先不变更,先改方案") time.sleep(random.randint(1, 3)) event.set() # 发回复给Operator,唤醒一个挂起的线程 event ★多进程之线程队列Queue 使 用 mul�processing.JoinableQueue() 方 法 创 建 一 个 队 列 , 它 与 queue.Queue的区别在于,它是多进程安全的,不用担心它的互斥和死 锁问题。 比如,有一个仓库用来存放商品,假如最多只能放5个商品,A不停的 放,B不停的取,A和B的放取速度不一致,就可以用队列来做 import multiprocessing import queue0 码力 | 213 页 | 3.53 MB | 1 年前3
共 1 条
- 1














