博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
python 继承式多线程
阅读量:7006 次
发布时间:2019-06-27

本文共 3991 字,大约阅读时间需要 13 分钟。

Thread是线程类,有两种使用方法,直接传入要运行的方法或从Thread继承并覆盖run():

 

Thread继承

 

import threadingimport timeclass MyThread(threading.Thread):    def __init__(self,n):        super(MyThread,self).__init__()        self.n = n    def run(self):        print("runnint task",self.n)t1 = MyThread("t1")t2 = MyThread("t2")t1.start() #runnint task t1t2.start() #runnint task t2

 以上是通过类的方式创建线程。

关于Thread

构造方法: 

Thread(group=None, target=None, name=None, args=(), kwargs={}) 

  group: 线程组,目前还没有实现,库引用中提示必须是None; 

  target: 要执行的方法; 
  name: 线程名; 
  args/kwargs: 要传入方法的参数。

实例方法: 

  isAlive(): 返回线程是否在运行。正在运行指启动后、终止前。 
  get/setName(name): 获取/设置线程名。 

  start():  线程准备就绪,等待CPU调度

  is/setDaemon(bool): 获取/设置是后台线程(默认前台线程(False))。(在start之前设置)

    如果是后台线程,主线程执行过程中,后台线程也在进行,主线程执行完毕后,后台线程不论成功与否,主线程和后台线程均停止

         如果是前台线程,主线程执行过程中,前台线程也在进行,主线程执行完毕后,等待前台线程也执行完成后,程序停止
  start(): 启动线程。 
  join([timeout]): 阻塞当前上下文环境的线程,直到调用此方法的线程终止或到达指定的timeout(可选参数)。

直接运行

 

 

将要执行的方法作为参数传给Thread的构造方法

import threadingimport timedef run(n):    print("task ",n)    time.sleep(2)    print('task done',n)start_time = time.time()for i in range(5):    t = threading.Thread(target=run,args=("t-%s" %i,))    t.start()print('cost:',time.time() - start_time )
1 task  t-0 2 task  t-1 3 task  t-2 4 task  t-3 5 task  t-4 6 cost: 0.0 #打印时间 停留2秒 继续执行 7 task done t-1 8 task done t-0 9 task done t-310 task done t-211 task done t-4
运行结果

 

一个程序至少有一个主线程。当一个线程启动一个子线程之后,那么相互是独立的、并行的。

主线程启动一个子线程之后并没有等待这个子线程执行完毕就往下走。

所以程序会一直执行到打印时间,也是程序结束。这个run()函数是子线程在执行,主线程执行完以后相当于创建完最后一个子线程,那么这个子线程继续执行run(),所以会等待2秒。在这之后又继续执行print('task done',n)。因为每个线程都是独立并行执行的。这个2秒是每个线程都要等待的。然后又执行print('task done',n)。

 以上只是测试了一个线程创建花费了多少时间。

怎么测试这些线程创建总共花费了多少时间?

默认情况下主线程执行并不会等待子线程,并且执行完毕了以后就退出了。

那么可以设置主线程等待子线程的执行结果,就可以计算创建子线程总共花费的时间。

join

join()等待子线程执行结果。程序默认是有一个join 因为要等待所有线程执行完毕以后才退出。

import threadingimport timeclass MyThread(threading.Thread):    def __init__(self,n):        super(MyThread,self).__init__()        self.n = n    def run(self):        print("runnint task",self.n)        time.sleep(2)t1 = MyThread("t1")t2 = MyThread("t2")t1.start()t1.join() #等待t1执行结果(等待2s)t2.start()

 加了join之后程序等待了2s之后在执行t2,t2有等待了2s之后程序结束。

相当于把并行的程序改成了串行。

先创建线程在等待。其实和没等待是一样的。因为这个程序还是在并行执行,等待t1的过程就是在等待所有线程的过程。

import threadingimport timeclass MyThread(threading.Thread):    def __init__(self,n):        super(MyThread,self).__init__()        self.n = n    def run(self):        print("runnint task",self.n)        time.sleep(2)t1 = MyThread("t1")t2 = MyThread("t2")t2.start()t1.start()t1.join() #等待t1执行结果(等待2s)print('main thread...')

 主要原因是因为每个线程的等待时间是一样的,所以看不出来,如果每个线程的创建时间不一样就可以看出效果。

import threadingimport timeclass MyThread(threading.Thread):    def __init__(self,n,sleep_time):        super(MyThread,self).__init__()        self.n = n        self.sleep_time = sleep_time    def run(self):        print("runnint task",self.n)        time.sleep(self.sleep_time)t1 = MyThread("t1",2)t2 = MyThread("t2",4)t1.start()t2.start()t1.join() #等待t1执行结果(等待2s)print('main thread...') #等待t2执行结果(等待2s)

 因为是一起创建的线程,所以等待的时间是一起计算的。要计算t2的创建时间也要等待t2结束,主程序才能结束。

import threadingimport timeclass MyThread(threading.Thread):    def __init__(self,n,sleep_time):        super(MyThread,self).__init__()        self.n = n        self.sleep_time = sleep_time    def run(self):        print("runnint task",self.n)        time.sleep(self.sleep_time)t1 = MyThread("t1",2)t2 = MyThread("t2",4)t1.start()t2.start()t1.join() #等待t1执行结果(等待2s)t2.join() #等待t2执行结果(等待2s)print('main thread...')

 

import threadingimport timedef run(n):    print("task ",n)    time.sleep(2)    print('task done',n)start_time = time.time()t_objs = []  #定义一个列表存放实例for i in range(5):    t = threading.Thread(target=run,args=("t-%s" %i,))    t.start()    t_objs.append(t) #为了不阻塞后面的线程的启动,不在这里join 先放到一个列表里for t in t_objs:   #循环每个实例    t.join()        print('cost:',time.time() - start_time )

 运行结果

task  t-0task  t-1task  t-2task  t-3task  t-4task done t-0task done t-4task done t-3task done t-2task done t-1cost: 2.004605770111084

 

参考 文章:

 

 

转载于:https://www.cnblogs.com/qing-chen/p/7675506.html

你可能感兴趣的文章
curl获取错误信息 php请求api接口方法
查看>>
织梦dedecms v5.7使用sql标签实现静态分页
查看>>
嵌入式工程师的发展路线
查看>>
Git命令集之七——差异查询命令
查看>>
kvm动态迁移
查看>>
Ubuntu14.04安装nodejs
查看>>
linux环境变量
查看>>
python为什么会作为***的首选语言?这几本书给你答案(已集齐)
查看>>
看过来!怎么恢复SD卡删除的文件?
查看>>
如何加快Python 应用的启动时间
查看>>
不可修改字符串NSString和可修改字符串NSMutableString
查看>>
django第一个app,4
查看>>
微信转发或分享朋友圈带缩略图、标题和描述的实现方法
查看>>
小程序一定要安装ssl证书吗
查看>>
Can't connect to local MySQL server through socket '/var/lib/mysql/mysql.sock'
查看>>
DB2 锁升级示例1
查看>>
启动网卡报错Failed to start LSB: Bring up/down network
查看>>
centos 升级4.0 内核
查看>>
Ubuntu配置永久生效的alias总结
查看>>
Tcp/Ip Http Socket的区别
查看>>