python3 使用threading模块进行多线程编码实现

python3 使用threading模块进行多线程编码实现

先说实现方式

使用threading.Thread(target=,args=)

继承threading.Thread并重写run方法

下面分别实现两种方式

使用threading.Thread(target=,args=)

import threading
import time

def music(name):
time.sleep(3)
print('music' + name)

def code(name):
print('code ' + name)

m = threading.Thread(target=music,args=('纯音乐',),name="我是线程1")
m.start()
print(m.name)
c = threading.Thread(target=code,args=('python',))
c.start()
print(c.name)

继承threading.Thread实现

import threading
import time

class Task(threading.Thread):
def run(self,func):
if func == 'music':
self.music()
elif func == 'code':
self.code()
else :
print('方法不存在')
def music(self):
time.sleep(3)
print('music')

def code(self):
print('code')

m = Task(name = '我是线程1')
m.run('music')
print(m.name)
c = Task()
c.run('code')
print(c.name)

threading.Thread中的属性与方法

Thread.getName()

Thread.setName()

Thread.name

用于获取和设置线程的名称

Thread.ident

获取线程的标识符。线程标识符是一个非零整数，只有在调用了start()方法之后该属性才有效，否则它只返回None。

Thread.is_alive()

Thread.isAlive()

判断线程是否是激活的（alive）。从调用start()方法启动线程，到run()方法执行完毕或遇到未处理异常而中断 这段时间内，线程是激活的

Thread.join([timeout])

调用Thread.join将会使主调线程堵塞，直到被调用线程运行结束或超时。参数timeout是一个数值类型，表示超时时间，如果未提供该参数，那么主调线程将一直堵塞到被调线程结束

Thread.Lock 与 Thread.RLock

当两个线程间有部分共享数据时，如果一个线程对Lock进行了acquire而在release之前，另一个线程也进行了acquire，那么就会造成两个线程互相等待的情况，此时就会造成死锁，而RLock则为可重入锁，RLock与Lock的内部各自维护有锁对象

import threading

#实例1
lock = threading.Lock()	#Lock对象
lock.acquire()
lock.acquire()  #产生了死琐。
lock.release()
lock.release()

#实例2
rLock = threading.RLock()  #RLock对象
rLock.acquire()
rLock.acquire()	#在同一线程内，程序不会堵塞。
rLock.release()
rLock.release()

Threading.Timer

threading.Timer是threading.Thread的子类，可以在指定时间间隔后执行某个操作

from threading import Timer
def hello():
print "hello, world"
t = Timer(3, hello)
t.start() # 3秒钟之后执行hello函数。

其他一些比较常用的方法

threading.active_count()

threading.activeCount()

获取当前活动的线程数量

threading.current_thread

threading.currentThread

获取当前的线程对象（Thread object）

threading.enumerate()

获取当前所有活动线程的列表。

threading.settrace(func)

设置一个跟踪函数，用于在run()执行之前被调用。

threading.setprofile(func)

设置一个跟踪函数，用于在run()执行完毕之后调用。