600字范文,内容丰富有趣,生活中的好帮手!
600字范文 > Python 多线程(threading模块)

Python 多线程(threading模块)

时间:2021-08-15 16:15:10

相关推荐

Python 多线程(threading模块)

首先,自己区分单线程和多线程的概念,自己去搜

单线程的例子如下:

[python]view plaincopyprint?__author__='MrChen' importthreading fromtimeimportctime,sleep #单线程 defmusic(music_name,length): foriinrange(4): print('Iwaslisteningto%s%s'%(music_name,ctime())) sleep(length) defmovie(movie_name,length): foriinrange(2): print('Iwasatthemovie%s%s'%(movie_name,ctime())) sleep(length) if__name__=='__main__': music('腐草为萤',2) movie('大话西游',4) print('allover%s'%ctime())

运行结果如下:

[python]view plaincopyprint?Iwaslisteningto腐草为萤SunOct2613:07:51 Iwaslisteningto腐草为萤SunOct2613:07:53 Iwaslisteningto腐草为萤SunOct2613:07:55 Iwaslisteningto腐草为萤SunOct2613:07:57 Iwasatthemovie大话西游SunOct2613:07:59 Iwasatthemovie大话西游SunOct2613:08:03 alloverSunOct2613:08:07

多线程的例子如下:

[python]view plaincopyprint?__author__='MrChen' importthreading fromtimeimportctime,sleep #多线程 defmusic(music_name,length): foriinrange(4): print('Iwaslisteningto%s%s'%(music_name,ctime())) sleep(length) defmovie(movie_name,length): foriinrange(2): print('Iwasatthemovie%s%s'%(movie_name,ctime())) sleep(length) th1=threading.Thread(target=music,args=('腐草为萤',1)) th2=threading.Thread(target=movie,args=('大话西游',2)) threads=[th1,th2] if__name__=='__main__': fortinthreads: t.setDaemon(True) t.start() t.join() print('allover%s'%ctime())

运行结果如下:

[python]view plaincopyprint?Iwaslisteningto腐草为萤SunOct2613:09:16 Iwasatthemovie大话西游SunOct2613:09:16 Iwaslisteningto腐草为萤SunOct2613:09:17 Iwaslisteningto腐草为萤SunOct2613:09:18 Iwasatthemovie大话西游SunOct2613:09:18 Iwaslisteningto腐草为萤SunOct2613:09:19 alloverSunOct2613:09:20

threading是python标准库中的模块,有些朋友查到会有thread这个模块,但是在python3里面只剩下threading这个模块了,因为threading模块用起来更简单也更安全一些

至于time模块,以后再讲,这里只需要知道time模块中有ctime(),sleep()等函数即可,ctime()返回当前时间,用一个str表示,sleep(n)表示挂起n秒

下面重点解释上面代码是怎么回事:

importthreading

导入threading模块

th1 = threading.Thread(target=music, args=('腐草为萤',1))

创建一个线程th1,threading.Thread()是一个类,类的构造函数原型如下:

class threading.Thread(group=None,target=None, name=None, args=(), kwargs={}, *, daemon=None)

这里用到了target,表示要调用的函数名,args表示调用函数的参数

threads = [th1, th2]

将两个线程放入一个列表中

for t in threads:

t.setDaemon(True)

t.start()

t.join()

最后使用一个for循环,依次将列表中的线程开启

t.setDaemon(True)

将线程声明为守护线程,必须在start()方法调用之前设置,如果不设置为守护线程程序会被无限挂起。子线程启动后,父线程也继续执行下去,当父线程执行完最后一条语句print"allover%s"%ctime()后,没有等待子线程,直接就退出了,同时子线程也一同结束。

t.start()

开始线程活动。

t.join()

join()方法,用于等待线程终止。join()的作用是,在子线程完成运行之前,这个子线程的父线程将一直等待。

注意:join()方法的位置是在for循环外的,也就是说必须等待for循环里的两个进程都结束后,才去执行主进程。如果没有join()函数,那么父线程执行完之后就会立即结束,不会等待子线程执行完

本内容不代表本网观点和政治立场,如有侵犯你的权益请联系我们处理。
网友评论
网友评论仅供其表达个人看法,并不表明网站立场。