python:threading多线程模块-创建线程


创建线程的两种方法:

1,直接调用threading.Thread来构造thread对象,Thread的参数如下:

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

group为None;

target为线程将要执行的功能函数;

name为线程的名字,也可以在对象构造后调用setName()来设定;

args为tuple类型的参数,可以为多个,如果只有一个也的使用tuple的形式传入,例如(1,);

kwargs为dict类型的参数,也即位命名参数

threading.Thread对象的其他方法:

start(),用来启动线程;

join(), 等待直到线程结束;

isAlive(),获取线程状态

 

setDeamon(), 设置线程为deamon线程,必须在start()调用前调用,默认为非demon。

注意: python的主线程在没有非deamon线程存在时就会退出。

 

threading.currentthread() , 用来获得当前的线程;

threading.enumerate() , 用来多的当前存活的所有线程;

 

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
#coding:utf-8
import  threading
def  func1(num):
     for  in  range (num):
         #threading.currentThread()获取当前线程,getName()获取线程名字
         print  'I am %s.num:%s'  %  (threading.currentThread().getName(), i)
                       
def  main(thread_num):
     thread_list  =  []  #定义一个线程列表
     for  in  range (thread_num):
         thread_list.append(threading.Thread(target = func1, args  =  ( 3 , )))
     for  in  thread_list:
         #a.setDaemon(True)这个setDaemon默认为False 非守护线程
         #表示主线程等所有子线程结束后,在结束
         #设置为True的话 表示是个守护线程 子线程就会随着主线程的结束而结束
         #听说服务监控工具生成的心跳线程 就是用的守护线程
         a.start()
                       
                       
     for  in  thread_list:
         a.join()  #表示等待直到线程运行完毕
                       
main( 3 )
#########运行结果######
>>> I am Thread - 1.num : 0
I am Thread - 1.num : 1
I am Thread - 1.num : 2
I am Thread - 2.num : 0
I am Thread - 2.num : 1
I am Thread - 2.num : 2
I am Thread - 3.num : 0
I am Thread - 3.num : 1
I am Thread - 3.num : 2

 

 

 

2,直接从threading.Thread继承,然后重写__init__方法和run方法

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
#coding:utf-8
import  threading
class  MyThread(threading.Thread):  #继承父类threading.Thread
     def  __init__( self , num ): 
         threading.Thread.__init__( self )
         self .num  =  num
          
     #把要执行的代码写到run函数里面 线程在创建后会直接运行run函数 
     def  run( self ):
         for  in  range ( self .num):
             print  'I am %s.num:%s'  %  ( self .getName(), i)
                 
for  in  range ( 3 ):
     =  MyThread( 3 )
     t.start()
     t.join()
##########运行结果#########
>>> I am Thread - 1.num : 0
I am Thread - 1.num : 1
I am Thread - 1.num : 2
I am Thread - 2.num : 0
I am Thread - 2.num : 1
I am Thread - 2.num : 2
I am Thread - 3.num : 0
I am Thread - 3.num : 1
I am Thread - 3.num : 2

 

本文出自 “师父领进门,修行靠个人!” 博客,请务必保留此出处http://zeping.blog.51cto.com/6140112/1258966


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM