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()执行完毕之后调用。

分享给朋友:
您可能感兴趣的文章:
随机阅读: