python多线程学习备忘录

男娘i 2022-06-15 00:54 198阅读 0赞

python提供了thread 和 threading 两个多线程模块。threading高级一些，大多数博客介绍的都是这个。

# 1.threading模块 #

threading模块提供的方法：  
\- threading.current\_thread()–返回当前线程的实例  
**threading.Thread线程类**  
进程默认会启动一个线程，即主线程，名称为”MainThread”。主线程可以创建其他子线程，子线程创建时默认的名称为”Thread-i” i表示第几个。  
**（1）创建线程**  
创建线程有两种方法：  
1）通过继承Thread类并重写run函数  
2）通过构造函数传入要运行的函数  
Thread(group=None, target=None, name=None, args=(), kwargs=\{\})  
\- group未实现  
\- target为要执行的方法  
\- name为线程名  
\- args对应target方法的参数

import threading#导入模块
    import time
    #通过target参数传入要执行的方法
    def actions(arg):
        time.sleep(1)
        print 'thread %s '%arg
    for i in xrange(5):
        t=threading.Thread(target=actions,args=(i,))
        t.start()
    #通过继承Thread类并重写run函数
    class MyThread(threading.Thread):
        def __init__(self,arg):
            #必须显式的调用父类的初始化函数
            super(MyThread,self).__init__()
            self.arg=arg
        def run(self):
            time.sleep(1)
            print 'thread %s'%self.arg
    for i in xrange(5):
        t=MyThread(i)
        t.start()

# 2.Thread类 #

Thread类提供的方法：  
\- start()–启动线程  
\- join()–等待至线程终止  
\- getName()–返回线程名称  
\- setName()–设置线程名称  
\- isAlive()–返回线程是否在运行  
\- setDaemon()–设置守护进程，必须在start()之前调用。  
python中thread的一些机制和C/C++不同：在C/C++中，主线程结束后，其子线程会默认被主线程kill掉。而在python中，主线程结束后，会默认等待子线程结束后，主线程才退出。  
(1) **设置setDaemon()**  
默认setDaemon(False),则该线程为用户线程。主线程执行完毕后，等待所有线程都执行完，程序再退出。  
setDaemon(True)，设置线程为守护线程(也有称之为后台线程）。主程序执行完毕后，不论守护线程是否执行完，程序退出。  
下面通过程序示例里展示setDeamon()的功能

#未设置setDeamon(),setDeamon(False)默认为False
    import threading
    print 'thread %s is running'%threading.current_thread().name
    def actions(arg):
        sleep(1)
        print 'thread %s is running\n'%threading.current_thread().name
        print 'thread %s \n'%arg
        sleep(1)
    for i in xrange(5):
        t=threading.Thread(target=actions,args=(i,))
        t.start()
    print 'thread %s is running'%threading.current_thread().name

运行结果

thread MainThread is running
    thread MainThread is ended
    thread Thread-1 is running
    thread 0
    thread Thread-5 is running
    thread Thread-4 is running
    thread Thread-3 is running
    thread Thread-2 is running
    thread 4
    thread 3
    thread 2
    thread 1
    #可以看出主线程MainThread结束后，其他线程任然继续执行。直到所有线程执行完，程序退出

设置setDaemon(True)

import threading
    print 'thread %s is running'%threading.current_thread().name
    def actions(arg):
        sleep(1)
        print 'thread %s is running\n'%threading.current_thread().name
        print 'thread %s \n'%arg
    for i in xrange(5):
        t=threading.Thread(target=actions,args=(i,))
        t.setDaemon(True)
        t.start()
    print 'thread %s is running'%threading.current_thread().name

运行结果

thread MainThread is running
    thread MainThread is ended
    #可以看出，设置子线程为守护线程，主线程执行完毕后，直接退出程序，不管守护线程的执行状况。

(2)join()阻塞当前上下文环境的线程，直到调用该方法的线程终止或到达timeout。如果主线程设置了setDaemon(True)依然要等待子线程结束。

print 'thread %s is running'%threading.current_thread().name
    def actions(arg):
        sleep(1)
        print 'thread %s is running\n'%threading.current_thread().name
        print 'thread %s \n'%arg
        sleep(1)
    threads=[]
    for i in xrange(5):
        t=threading.Thread(target=actions,args=(i,))
        t.setDaemon(True)
        threads.append(t)
    for t in threads:
        t.start()
    for t in threads:
        t.join()
    print 'thread %s is ended'%threading.current_thread().name

运行结果

thread MainThread is running
    thread Thread-3 is running
    thread Thread-5 is running
    thread Thread-4 is running
    thread Thread-2 is running
    thread Thread-1 is running
    thread 2
    thread 4
    thread 3
    thread 1
    thread 0
    thread MainThread is ended
    #设置join()后，主线程等待所有子线程完成执行或超时后再结束。

【join()方法使得线程可以等待另一个线程的运行，而setDaemon()方法使得主线程在结束时不等待子线程。join和setDaemon都可以改变线程之间的运行顺序】  
参考博客：

# 3.线程同步 #

当多个线程对同一个数据项进行修改，就需要锁来保证数据的正确性。通过threading模块的Lock和Rlock类来实现。  
**Lock和Rlock类**  
这两个类都有acquire方法（获得锁）和release方法（释放锁）  
Lock–只有锁定和非锁定两种状态，不能重复acquire  
Rlock–可以被同一个线程acquire多次，但acquire和release必须成对出现

*  [http://www.runoob.com/python/python-multithreading.html][http_www.runoob.com_python_python-multithreading.html]
 *  [http://www.cnblogs.com/tkqasn/p/5700281.html][http_www.cnblogs.com_tkqasn_p_5700281.html]
 *  [http://f.dataguru.cn/thread-170832-1-1.html][http_f.dataguru.cn_thread-170832-1-1.html]

[http_www.runoob.com_python_python-multithreading.html]: http://www.runoob.com/python/python-multithreading.html
[http_www.cnblogs.com_tkqasn_p_5700281.html]: http://www.cnblogs.com/tkqasn/p/5700281.html
[http_f.dataguru.cn_thread-170832-1-1.html]: http://f.dataguru.cn/thread-170832-1-1.html