forked from vipstone/python
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy path多线程.md
144 lines (97 loc) · 3.38 KB
/
多线程.md
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
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
多线程
----------
python是一门解析性语言，python的解析器默认也是单线程的，但python3提供几个用于多线程编程的模块，_thread、threading
。
python2中的thread已经废弃，为了兼容性在python3中使用_thread代替，_thread提供了原始的线程操作和简单的锁，推荐使用threading模块。
## _thread模块 ##
_thread模块实现多线程，使用_thread.start_new_thread()方法实现，示例如下：
```
import _thread
import time
def sayHi(name):
num = 0
while num < 5:
num += 1
time.sleep(1)
print("%s执行——现在时间：%s\n" % (name, time.strftime(
"%Y-%m-%d %H:%M:%S", time.localtime(time.time()))))
try:
_thread.start_new_thread(sayHi, ("线程1",))
_thread.start_new_thread(sayHi, ("线程2",))
except:
print("线程启动失败")
# 保持主线程10s后退出
time.sleep(10)
# 输出结果如下：
# 线程1执行——现在时间：2018-04-12 14: 30: 38
# 线程2执行——现在时间：2018-04-12 14: 30: 38
# 线程1执行——现在时间：2018-04-12 14: 30: 39
# 线程2执行——现在时间：2018-04-12 14: 30: 39
# 线程2执行——现在时间：2018-04-12 14: 30: 40
# 线程1执行——现在时间：2018-04-12 14: 30: 40
# 线程1执行——现在时间：2018-04-12 14: 30: 41
# 线程2执行——现在时间：2018-04-12 14: 30: 41
# 线程2执行——现在时间：2018-04-12 14: 30: 42
# 线程1执行——现在时间：2018-04-12 14: 30: 42
```
## threading模块 ##
threading除了包含_thread的所有方法外，还提供了其他方法：
threading.currentThread()：返回当前线程变量
threading.enumerate()：返回正在运行的线程列表
threading.activeCount()：返回当前正在运行的线程数量和len(threading.enumerate())效果相同
run()：用于表示线程活动的方法
start()：启动线程活动
join([time])：等待至线程结束
isAlive()：线程是否是活跃的
getName()：返回线程名
setName()：设置线程名
**threading基础使用**
```
import time
import threading
class myThreading(threading.Thread):
def __init__(self, name):
threading.Thread.__init__(self)
self.name = name
def run(self):
time.sleep(1)
print("%s 时间：%s" %
(self.name, time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(time.time()))))
td1 = myThreading("threading1")
td2 = myThreading("threading2")
td1.start()
td2.start()
td1.join()
td2.join()
# 输出：
# Thread-1 时间：2018-04-14 11:19:54
# Thread-2 时间：2018-04-14 11:19:54
```
**threading线程同步**
threading使用threading.Lock()来同步线程，threading.Lock()包含锁定的方法acquire()和解锁的方法release()来同步线程，示例如下：
```
import time
import threading
class myThreading(threading.Thread):
def __init__(self, name):
threading.Thread.__init__(self)
self.name = name
def run(self):
# 上锁
threadLock.acquire()
time.sleep(1)
print("%s 时间：%s" %
(self.name, time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(time.time()))))
# 解锁
threadLock.release()
# 声明线程同步锁
threadLock = threading.Lock()
td1 = myThreading("threading1")
td2 = myThreading("threading2")
td1.start()
td2.start()
td1.join()
td2.join()
```
----------
下一节：[时间模块](时间模块.md)