#!/usr/bin/env python
#-*-coding:utf-8-*-
#多进程
import threading
import time
def thfun():s=0for i in range(30):s+=itime.sleep(0.1)print(s)class MyThread(threading.Thread):def run(self):s=0for i in range(30):s+=itime.sleep(0.1)print(s)if __name__=='__main__':#ths=[threading.Thread(target=thfun) for i in range(2)]ths=[MyThread() for i in range(2)]for th in ths:th.start()#!/usr/bin/env python
#-*-coding:utf-8-*-
#线程间等待 join 线程等待
import threading,timeclass MyThread(threading.Thread):def run(self):for i in range(30):print('threading:',i)time.sleep(0.1)if __name__=='__main__':t=MyThread()t.start()#制定超时1s#t.join(1)t.join()for i in range(10):print('Main:',i)time.sleep(0.1)
#!/usr/bin/env python
#-*-coding:utf-8-*-
#后台线程 daemon
#后台线程不会结束import threading,timedef dmn():print('dmn start...')time.sleep(2)print('dmn end.')def ndmn():print('ndmn start...')time.sleep(1)print('ndmn end.')d=threading.Thread(target=dmn)
#后台线程
d.daemon=True
n=threading.Thread(target=ndmn)print('start...')
d.start()
n.start()
print('end...')#!/usr/bin/env python
#-*-coding:utf-8-*-
#线程等待，指令锁 可重入锁,acquire(blocking=True,timeout=-1) release() threading.RLock
import threading,time,randomshare=4class MyThread(threading.Thread):def __init__(self,i):super().__init__()self.i=idef run(self):global share for d in range(3):lock.acquire()print(share)share+=self.itime.sleep(random.random())print('+',self.i,'=',share)lock.release()lock=threading.Lock()if __name__=='__main__':t=MyThread(2)tt=MyThread(6)t.start()tt.start()#!/usr/bin/env python
#-*-coding:utf-8-*-
#条件变量 生产者，消费者
import threading,timeshare=0share_cond=threading.Condition()class ProThread(threading.Thread):def __init__(self):super().__init__()self.name='Produce'def run(self):global shareif share_cond.acquire():while True:if not share:share+=1print(self.name,share)#唤醒需要本资源的线程share_cond.notify()share_cond.wait()time.sleep(1)#消费者
class CustomThread(threading.Thread):def __init__(self):super().__init__()self.name="Custom"def run(self):global shareif share_cond.acquire():while True:if share:share-=1print(self.name,share)share_cond.notify()share_cond.wait()time.sleep(1)
if __name__=='__main__':t=ProThread()tt=CustomThread()t.start()tt.start()#!/usr/bin/env python
#-*-coding:utf-8-*-
#线程同步，信号量
import threading, timesema=threading.Semaphore(2)
#资源的个数class MyThread(threading.Thread):def __init__(self,name):super().__init__()self.name=namedef run(self):#获得一个资源if sema.acquire():print(self.name,'Had got resource.')time.sleep(1)sema.release()print(self.name,'Had released resource.')
if __name__=='__main__':ths=[MyThread(str(i)+'Sema') for i in range(5)]for th in ths:th.start()
#!/usr/bin/env python
#-*-coding:utf-8-*-
#等待线程 ,线程通信
#定时执行 threading.Timer threading.Timer(3,start)import threading
import timeevent=threading.Event()#等待线程
class MyThreadWait(threading.Thread):def run(self):self.name='Wait Thread'print(self.name,'Wait...')event.wait()#等到内部标记为Trueprint(self.name,'Start...')event.clear()class MyThreadMain(threading.Thread):def run(self):time.sleep(3)print('Main thread set event flag!')event.set()#内部标记为空if __name__=='__main__':thw=MyThreadWait()thm=MyThreadMain()thw.start()thm.start()