python中threading模块详解

刺骨的言语ヽ痛彻心扉 2022-07-30 15:23 161阅读 0赞

[python中threading模块详解（一）][python_threading] *2013-01-30 13:10:24*

*http://blog.chinaunix.net/uid-27571599-id-3484048.html*

分类： Python/Ruby

threading提供了一个比thread模块更高层的API来提供线程的并发性。这些线程并发运行并共享内存。

下面来看threading模块的具体用法：

一、Thread的使用 目标函数可以实例化一个Thread对象，每个Thread对象代表着一个线程，可以通过start()方法，开始运行。

这里对使用多线程并发，和不适用多线程并发做了一个比较：

首先是不使用多线程的操作：

代码如下：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div> 
    <div>
      12 
    </div> </td> 
   <td> 
    <div> 
     <div> 
      <code>#!/usr/bin/python</code> 
     </div> 
     <div> 
      <code>#compare for multi threads</code> 
     </div> 
     <div> 
      <code>import</code> 
      <code> time</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>def</code> 
      <code> worker():</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>print</code> 
      <code>"worker"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>time.sleep(</code> 
      <code>1</code> 
      <code>)</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>return</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>if</code> 
      <code> __name__ </code> 
      <code>=</code> 
      <code>=</code> 
      <code>"__main__"</code> 
      <code>:</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>for</code> 
      <code>i </code> 
      <code>in</code> 
      <code> xrange</code> 
      <code>(</code> 
      <code>5</code> 
      <code>):</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>worker()</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

执行结果如下：

![27571599_1359521436q2L3.png][]

下面是使用多线程并发的操作：

代码如下：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div> 
    <div>
      12 
    </div> </td> 
   <td> 
    <div> 
     <div> 
      <code>#!/usr/bin/python</code> 
     </div> 
     <div> 
      <code>import</code> 
      <code> threading</code> 
     </div> 
     <div> 
      <code>import</code> 
      <code> time</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>def</code> 
      <code> worker():</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>print</code> 
      <code>"worker"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>time.sleep(</code> 
      <code>1</code> 
      <code>)</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>return</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>for</code> 
      <code> i </code> 
      <code>in</code> 
      <code>xrange</code> 
      <code>(</code> 
      <code>5</code> 
      <code>):</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>t </code> 
      <code>=</code> 
      <code>threading.Thread(target</code> 
      <code>=</code> 
      <code>worker)</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>t.start()</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

![27571599_1359521358Rwdx.png][]

可以明显看出使用了多线程并发的操作，花费时间要短的很多。

二、threading.activeCount()的使用，此方法返回当前进程中线程的个数。返回的个数中包含主线程。

代码如下：

![27571599_13595220138wLU.png][]

三、threading.enumerate()的使用。此方法返回当前运行中的Thread对象列表。

代码如下：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div> 
    <div>
      12 
    </div> 
    <div>
      13 
    </div> 
    <div>
      14 
    </div> 
    <div>
      15 
    </div> 
    <div>
      16 
    </div> 
    <div>
      17 
    </div> 
    <div>
      18 
    </div> 
    <div>
      19 
    </div> 
    <div>
      20 
    </div> 
    <div>
      21 
    </div> 
    <div>
      22 
    </div> </td> 
   <td> 
    <div> 
     <div> 
      <code>#!/usr/bin/python</code> 
     </div> 
     <div> 
      <code>#test the variable threading.enumerate()</code> 
     </div> 
     <div> 
      <code>import</code> 
      <code> threading</code> 
     </div> 
     <div> 
      <code>import</code> 
      <code> time</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>def</code> 
      <code> worker():</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>print</code> 
      <code>"test"</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>time.sleep(</code> 
      <code>2</code> 
      <code>)</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>threads </code> 
      <code>=</code> 
      <code>[]</code> 
     </div> 
     <div> 
      <code>for</code> 
      <code> i </code> 
      <code>in</code> 
      <code>xrange</code> 
      <code>(</code> 
      <code>5</code> 
      <code>):</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>t </code> 
      <code>=</code> 
      <code>threading.Thread(target</code> 
      <code>=</code> 
      <code>worker)</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>threads.append(t)</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>t.start()</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>for</code> 
      <code> item </code> 
      <code>in</code> 
      <code>threading.</code> 
      <code>enumerate</code> 
      <code>():</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>print</code> 
      <code>item</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>print</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>for</code> 
      <code> item </code> 
      <code>in</code> 
      <code>threads:</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>print</code> 
      <code>item</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

![27571599_1359522276rYPS.png][]

四、threading.setDaemon()的使用。设置后台进程。

代码如下：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div> 
    <div>
      12 
    </div> 
    <div>
      13 
    </div> </td> 
   <td> 
    <div> 
     <div> 
      <code>#!/usr/bin/python</code> 
     </div> 
     <div> 
      <code>#create a daemon</code> 
     </div> 
     <div> 
      <code>import</code> 
      <code> threading</code> 
     </div> 
     <div> 
      <code>import</code> 
      <code> time</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>def</code> 
      <code> worker():</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>time.sleep(</code> 
      <code>3</code> 
      <code>)</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>print</code> 
      <code>"worker"</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>t</code> 
      <code>=</code> 
      <code>threading.Thread(target</code> 
      <code>=</code> 
      <code>worker)</code> 
     </div> 
     <div> 
      <code>t.setDaemon(</code> 
      <code>True</code> 
      <code>)</code> 
     </div> 
     <div> 
      <code>t.start()</code> 
     </div> 
     <div> 
      <code>print</code> 
      <code> "haha"</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

![27571599_1359522490E18Q.png][]

可以看出worker（）方法中的打印操作并没有显示出来，说明已经成为后台进程。

[python_threading]: http://blog.chinaunix.net/uid-27571599-id-3484048.html
[27571599_1359521436q2L3.png]: http://blog.chinaunix.net/attachment/201301/30/27571599_1359521436q2L3.png
[27571599_1359521358Rwdx.png]: http://blog.chinaunix.net/attachment/201301/30/27571599_1359521358Rwdx.png
[27571599_13595220138wLU.png]: http://blog.chinaunix.net/attachment/201301/30/27571599_13595220138wLU.png
[27571599_1359522276rYPS.png]: http://blog.chinaunix.net/attachment/201301/30/27571599_1359522276rYPS.png
[27571599_1359522490E18Q.png]: http://blog.chinaunix.net/attachment/201301/30/27571599_1359522490E18Q.png