Python中创建线程有两种方式:函数或者用类来创建线程对象。
函数式:调用 _thread 模块中的start_new_thread()函数来产生新线程。
类:创建threading.Thread的子类来包装一个线程对象。
1.线程的创建
1.1 通过thread类直接创建
import threading import time def foo(n): time.sleep(n) print("foo func:",n) def bar(n): time.sleep(n) print("bar func:",n) s1=time.time() #创建一个线程实例t1,foo为这个线程要运行的函数 t1=threading.Thread(target=foo,args=(3,)) t1.start() #启动线程t1 #创建一个线程实例t2,bar为这个线程要运行的函数 t2=threading.Thread(target=bar,args=(5,)) t2.start() #启动线程t2 print("ending") s2=time.time() print("cost time:",s2-s1)
在这段程序里,一个函数会先休眠几秒钟,然后再打印一句话,第二个函数也是先休眠几秒钟,然后打印一句话。
接着程序会实例化两个线程,并调用两个函数来执行,最后会打印程序问总共执行了多少时间
程序运行结果如下:
endingcost time: 0.002000093460083008foo func: 3bar func: 5
程序会先运行父线程,打印"ending",然后打印程序执行父线程的时间,最后才会运行子线程
1.2 通过thread类来继承式创建
import threading import time # 定义MyThread类,其继承自threading.Thread这个父类 class MyThread(threading.Thread): def __init__(self): threading.Thread.__init__(self) def run(self): print("ok") time.sleep(2) print("end t1") # 对类进行实例化 t1=MyThread() # 启动线程 t1.start() print("ending")
2. Thread类的一些常用方法
2.1 join():在子线程完成之前,主线程将一直被阻塞****
线程的join方法必须在子线程的start方法之后定义
在第一个例子中加入两行代码,如下:
import threading import time def foo(n): time.sleep(n) print("foo func:",n) def bar(n): time.sleep(n) print("bar func:",n) s1=time.time() t1=threading.Thread(target=foo,args=(3,)) t1.start() t2=threading.Thread(target=bar,args=(5,)) t2.start() t1.join() # 阻塞t1线程 t2.join() # 阻塞t2线程 print("ending") s2=time.time() print("cost time:",s2-s1)
再次执行程序,运行结果如下:
foo func: 3bar func: 5endingcost time: 5.002285957336426
程序运行到子线程t1中的foo方法时会睡眠3秒钟,与此同时,子线程t2也在睡眠
等到子线程t1睡眠完成后,开始打印foo函数中的print语句,然后子线程t1执行完成
2秒钟之后,子线程t2睡眠完成,开始打印bar函数中的print语句,然后子线程t2也执行完成。
而在这之前,主线程一直处于阻塞状态。等到子线程执行完成之后主线程才会执行
新闻热点
疑难解答