python：线程进阶

发布时间：2020-12-17 00:01:24 所属栏目：Python 来源：网络整理

导读：1，守护线程 threading ( 3 ( t = Thread(target=span style="color: #000000"func) t.setDaemon(True) span style="color: #008000"# span style="color: #008000" 进程设置守护进程是一个属性 daemon = True span style="color: #000000"t.start() t2 = T

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"> 在多线程中 特殊情况 仍然要加锁 对数据

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