《python核心编程》读书笔记-threading模块

矫情吗；* 2022-03-27 02:06 173阅读 0赞

# 简介 #

在Python提供了多个模块支持多线程编程，包括thread，threading和Queue模块等，推荐使用threading

# threading模块对象 #

<table> 
 <thead> 
  <tr> 
   <th>对象</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>Thread</td> 
   <td>表示一个执行线程的对象</td> 
  </tr> 
  <tr> 
   <td>Lock</td> 
   <td>锁原语对象</td> 
  </tr> 
  <tr> 
   <td>RLock</td> 
   <td>可重入锁对象，使单一线程可以（再次）获得已持有的锁（递归锁）</td> 
  </tr> 
  <tr> 
   <td>Condition</td> 
   <td>条件变量对象，使得一个线程等待另一个线程满足特定的“条件”，比如改变状态或某个数据值</td> 
  </tr> 
  <tr> 
   <td>Event</td> 
   <td>条件变量的通用版本，任意数量的线程等待某个事件的发生，在该事件发生后所有线程将被激活</td> 
  </tr> 
  <tr> 
   <td>Semaphore</td> 
   <td>为线程间共享的有限资源提供了一个“计数器”，如果没有可用资源时会被阻塞</td> 
  </tr> 
  <tr> 
   <td>BoundedSemaphore</td> 
   <td>与 Semaphore 相似，不过它不允许超过初始值</td> 
  </tr> 
  <tr> 
   <td>Timer</td> 
   <td>与 Thread 相似，不过它要在运行前等待一段时间</td> 
  </tr> 
  <tr> 
   <td>Barrier</td> 
   <td>创建一个障碍，必须达到指定数量的线程才可以继续</td> 
  </tr> 
 </tbody> 
</table>

# Thread类属性和方法 #

### Thread 对象数据属性 ###

<table> 
 <thead> 
  <tr> 
   <th>Thread 对象数据属性</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>name</td> 
   <td>线程名</td> 
  </tr> 
  <tr> 
   <td>ident</td> 
   <td>线程的标识符</td> 
  </tr> 
  <tr> 
   <td>daemon</td> 
   <td>布尔标志，表示这个线程是否是守护线程</td> 
  </tr> 
 </tbody> 
</table>

### Thread 对象方法 ###

<table> 
 <thead> 
  <tr> 
   <th>Thread 对象方法</th> 
   <th>描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>__init__(group=None, tatget=None,args=(), kwargs ={}, verbose=None, daemon=None)</td> 
   <td>实例化一个线程对象，需要有一个可调用的 target，以及其参数 args或 kwargs。还可以传递 name 或 group 参数，不过后者还未实现。此外 ， verbose 标 志 也 是 可 接 受 的。 而 daemon 的 值 将 会 设定thread.daemon 属性/标志</td> 
  </tr> 
  <tr> 
   <td>start()</td> 
   <td>开始执行该线程</td> 
  </tr> 
  <tr> 
   <td>run()</td> 
   <td>定义线程功能的方法（通常在子类中被应用开发者重写）</td> 
  </tr> 
  <tr> 
   <td>join (timeout=None)</td> 
   <td>直至启动的线程终止之前一直挂起；除非给出了 timeout（秒），否则会一直阻塞</td> 
  </tr> 
  <tr> 
   <td>getName()</td> 
   <td>返回线程名</td> 
  </tr> 
  <tr> 
   <td>setName (name)</td> 
   <td>设定线程名</td> 
  </tr> 
  <tr> 
   <td>isAlivel /is_alive ()</td> 
   <td>布尔标志，表示这个线程是否还存活</td> 
  </tr> 
  <tr> 
   <td>isDaemon()</td> 
   <td>如果是守护线程，则返回 True；否则，返回 False</td> 
  </tr> 
  <tr> 
   <td>setDaemon(daemonic)</td> 
   <td>把线程的守护标志设定为布尔值 daemonic（必须在线程 start()之前调用）</td> 
  </tr> 
 </tbody> 
</table>

# 创建Thread的实例1 #

来自《python核心编程》中的例程

import threading
    from time import sleep,ctime
    
    loops = [5,2]
    
    def loop(nloop,nsec):
        print('start  loop',nloop,'at:',ctime())
        sleep(nsec)
        print('loop',nloop,'done at:',ctime())
    
    
    def main():
        print('starting at:',ctime())
        threads=[]
        nloops = range(len(loops))
    
        for i  in nloops:
            t = threading.Thread(target=loop, args=(i, loops[i]))
            threads.append(t)
    
        for i in nloops:
            threads[i].start()
    
        for i in nloops:
            threads[i].join()
            
        print('all done at:',ctime())
    
    
    if __name__=='__main__':
        main()

运行结果  
![在这里插入图片描述][20190111165858990.png]

# 创建Thread的实例2 #

功能和实例1没什么区别，让这个类更加通用，而不是局限于loop()函数，因此添加了一些新东西，比如让这个类保存了函数的参数，函数自身，以及函数名的字符串，而构造函数\_\_init\_\_()用于设定上述的这些值。  
当创建新线程的时候，Thread类的代码将调用ThreadFunc对象，此时会调用\_\_call\_\_()这个特殊方法，用于已经有了需要的参数，于是就不需要再将其传递给Thread()的构造函数了，直接调用就可以了

import threading
    from time import sleep,ctime
    
    loops = [5,2]
    
    class ThreadFunc(object):
    
        def __init__(self,func,args,name=''):
            self.name = name
            self.func = func
            self.args = args
    
        def __call__(self, *args, **kwargs):
            self.func(*self.args)
    
    def loop(nloop,nsec):
        print('start  loop',nloop,'at:',ctime())
        sleep(nsec)
        print('loop',nloop,'done at:',ctime())
    
    
    def main():
        print('starting at:',ctime())
        threads=[]
        nloops = range(len(loops))
    
        for i  in nloops:
            t = threading.Thread(target=ThreadFunc(loop,(i,loops[i]),loop.__name__))
            threads.append(t)
    
        for i in nloops:
            threads[i].start()
    
        for i in nloops:
            threads[i].join()
    
    
        print('all done at:',ctime())
    
    
    if __name__=='__main__':
        main()

运行结果  
![在这里插入图片描述][20190111203625559.png]

[20190111165858990.png]: /images/20220327/64efac04aba04945ab0ad42aad4f9509.png
[20190111203625559.png]: /images/20220327/c677a616951549c7918e16757dde1339.png