1，守护线程

threading (3(t = Thread(target=func)
t.setDaemon(True) # 进程设置守护进程是一个属性 daemon = True
t.start()
t2 = Thread(target=func)
t2.start()
t2.join() # 等待t2结束

# 守护线程 守护进程 都是等待主进程或者主线程中的代码 执行完毕# t2 = Thread(target=func)# t2.start()   ---> 代码执行完毕# 守护线程就结束了# 主线程还没结束 等待t2继续执行# t2执行完毕 主线程结束# t2 = Thread(target=func)# t2.start()# t2.join()  # 等待t2结束 执行完这句话代码才执行完毕# t2线程执行完毕# 主线程中没有代码了，守护线程结束

2，锁

threading threading 2= n
time.sleep(0.01= temp-1
n = 100
lock = Lock()
t_lst = []
for i in range(100):
t = Thread(target=func)
t.start()
t_lst.append(t)
[t.join() for t in t_lst]
print(n)

# GIL 不是锁数据而是锁线程

在多线程中特殊情况仍然要加锁对数据

3，死锁

threading threading = kz = RLock()

(%(%(%def eat2(name):
m.acquire() # 没有钥匙
print('%s拿到菠萝蜜干了’ % name)
time.sleep(1)
kz.acquire()
print('%s拿到筷子了’ % name)
print('%s吃菠萝蜜干’ % name)
kz.release()
m.release()

Thread(target=eat,args=('兔子',)).start()Thread(target=eat2,args=('rabbit',)).start()Thread(target=eat,args=('大橘',args=('Orange_Cat',)).start()

在不同的线程中 恰好要对这两个数据进行操作所以就出现了死锁。4，信号量

threading threading (% ( % sem = Semaphore(5)
i range(20 Thread(target=func,args=

5，事件

threading threading conn_mysql():
count = 1
e.is_set():
count>3(%+= 10.5)
()

def check_conn():
”'
检测数据库服务器的连接是否正常
”'
time.sleep(random.randint(1,2)) # 模拟连接检测的时间
e.set() # 告诉事件的标志数据库可以连接

e = Event()
check = Thread(target=check_conn)
check.start()
conn = Thread(target=conn_mysql)
conn.start()

6，条件

( %if name == 'main':
con = threading.Condition() # 条件 = 锁 + wait的功能
for i in range(10):
t = threading.Thread(target=run,))
t.start()

</span><span style="color: #0000ff"&gt;while</span><span style="color: #000000"&gt; True:
    inp </span>= input(<span style="color: #800000"&gt;'</span><span style="color: #800000"&gt;>>></span><span style="color: #800000"&gt;'</span><span style="color: #000000"&gt;)
    </span><span style="color: #0000ff"&gt;if</span> inp == <span style="color: #800000"&gt;'</span><span style="color: #800000"&gt;q</span><span style="color: #800000"&gt;'</span><span style="color: #000000"&gt;:
        </span><span style="color: #0000ff"&gt;break</span><span style="color: #000000"&gt;
    con.acquire()        </span><span style="color: #008000"&gt;#</span><span style="color: #008000"&gt; condition中的锁  是递归锁</span>
    <span style="color: #0000ff"&gt;if</span> inp == <span style="color: #800000"&gt;'</span><span style="color: #800000"&gt;all</span><span style="color: #800000"&gt;'</span><span style="color: #000000"&gt;:
        con.notify_all()
    </span><span style="color: #0000ff"&gt;else</span><span style="color: #000000"&gt;:
        con.notify(int(inp))   </span><span style="color: #008000"&gt;#</span><span style="color: #008000"&gt; 传递信号 notify(1) --> 可以放行一个线程</span>
    con.release()</pre>

7，计时器

threading def hello():
print(”hello,world”)
while True: # 每隔一段时间要开启一个线程
t = Timer(10,hello) # 定时开启一个线程，执行一个任务
# 定时：多久之后单位是s
# 要执行的任务：函数名
t.start()

8，队列

= queue.PriorityQueue()
pq.put((1,1,15,2,(pq.get())

9，concurrent与线程池和回调函数

concurrent 1,3 n*
= futures.ThreadPoolExecutor(5)
thread_pool.map(funcname,range(10))
f_lst = i range(10= thread_pool.submit(funcname,i)

f f_lst:
(f.result())
thread_pool.submit(funcname,1).add_done_callback(call)

青岛站长网

python：线程进阶

<span style=”color: #008000″> 在多线程中特殊情况仍然要加锁对数据

作者: dawei

<span style=”color: #008000″> 在多线程中 特殊情况 仍然要加锁 对数据

作者: dawei

为您推荐

python – 如何使用输入函数和def函数？

python – 你如何从雅虎财经中提取每周的历史数据？

python – 覆盆子pi上的多个热电偶

在Python中处理不同类型的规范方法是什么？

Python 2和3之间的类型差异

python – igraph：为什么add_edge函数如此缓慢地对add_edges？

<span style=”color: #008000″> 在多线程中特殊情况仍然要加锁对数据