-
Notifications
You must be signed in to change notification settings - Fork 223
Expand file tree
/
Copy pathevent.py
More file actions
89 lines (68 loc) · 2.56 KB
/
event.py
File metadata and controls
89 lines (68 loc) · 2.56 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
#!/usr/bin/env python3
# -*- coding: utf-8 -*-
"""
@FileName: event.py
@Function: 多线程、多进程同步之Event
@Author: Zhihe An
@Site: https://chegva.com
@Time: 2021/7/31
"""
"""一、多线程同步之Event"""
"""
标准库模块threading中提供了一个类对象Event，也可以实现多线程间的同步。Event实例对象管理着
一个内部标志，通过改变这个内部标志的值，可以让一个线程给其它处于阻塞状态的线程发送一个事件信号，
从而唤醒这些线程让它们转为运行状态。
Event的方法如下：
(1) set(self)
将内部标志设置为True
(2) is_set(self)
判断内部标志是否被设置为True
(3) clear(self)
将内部标志设置为False
(4) wait(self, timeout=None)
当内部标志为False时，调用该方法的线程会被阻塞
直到另外一个线程调用了方法set()将内部标志设置为True，被阻塞的线程才会转为运行状态
"""
"""
from threading import Thread, Event, current_thread
import time
event = Event()
print(event.is_set()) # False
def do_sth():
print('%s开始等待' % current_thread().getName())
event.wait()
print('%s结束等待' % current_thread().getName())
for i in range(3):
Thread(target=do_sth).start()
time.sleep(2)
event.set()
"""
"""二、多进程同步之Event"""
"""
标准库模块multiprocessing中提供了一个类对象Event，也可以实现多进程间的同步。Event实例对象管理着
一个内部标志，通过改变这个内部标志的值，可以让一个进程给其它处于阻塞状态的进程发送一个事件信号，
从而唤醒这些进程让它们转为运行状态。
Event的方法如下：
(1) set(self)
将内部标志设置为True
(2) is_set(self)
判断内部标志是否被设置为True
(3) clear(self)
将内部标志设置为False
(4) wait(self, timeout=None)
当内部标志为False时，调用该方法的进程会被阻塞
直到另外一个进程调用了方法set()将内部标志设置为True，被阻塞的进程才会转为运行状态
"""
from multiprocessing import Process, Event, current_process
import time
def do_sth(event):
print('%s开始等待' % current_process().pid)
event.wait()
print('%s结束等待' % current_process().pid)
if __name__ == '__main__':
event = Event()
print(event.is_set()) # False
for i in range(3):
Process(target=do_sth, args=(event,)).start()
time.sleep(2)
event.set()