python 中创建线程

nics

进程是操作系统中应用程序的执行实例，而线程是进程内部的一个执行单元。当系统创建一个进程后，也就创建了一个主线程。每个进程至少有一个线程，也可以有多个线程。在程序中使用多线程可以实现并行处理，充分利用CPU。Python提供了对多线程的支持。在Python中可以方便地使用多线程进行编程。

1  线程基础

Python提供了thread、threading模块对多线程编程的支持。threading模块是对thread模块的封装。多数情况下应该是用threading模块来进行多线程编程。

2  创建线程

在Python中可以通过使用thread模块中的函数，或者通过继承threading类来创建线程。编程创建后还可以对其进行操作。

2.1 使用thread模块创建线程

thread模块提供了start_new_thread函数，用以创建线程。start_new_thread函数成功创建线程后将返回线程标识。其函数原型如下所示。
start_new_thread( function, args[, kwargs])

其参数含义如下。

function：在线程中执行的函数名。

args：元组形式的参数列表。

kwargs：可选参数，以字典的形式指定参数。

以下代码首先定义一个函数，然后使用start_new_thread创建一个线程运行该函数。



>>> import thread      # 导入thread模块
>>> def run(n):       # 定义run函数
...  for i in range(n):
...   print i
...   
>>> thread.start_new_thread(run,(4,))  # 使用start_new_thread函数创建线程
3668          # 返回线程的标识
>>> 0         # 此处为run函数的输出
1
2
3
>>> thread.start_new_thread(run,(2,))  # 使用start_new_thread函数创建线程
1388          # 返回线程的标识
>>> 0         # 此处为run函数的输出
1
>>> thread.start_new_thread(run,(),{'n':4}) # 使用字典向函数传递参数
3896
>>> 0
1
2
3

2。2 使用threading模块创建线程

通过继承threading模块中的Thread创建新类，重载run方法后，可以通过start方法创建线程。线程创建后将运行run方法。以下代码使用threading模块创建线程。



>>> import threading      # 导入threading模块
>>> class mythread(threading.Thread):  # 通过继承Thread创建类
...   def _init_(self,num):    # 定义初始化方法
...   threading.Thread.__init__(self)  # 调用父类的初始化方法
...   self.num = num
...   def run(self):      # 重载run方法
...   print 'I am ',self.num
...   
>>> t1 = mythread(1)      # 生成mythread对象
>>> t2 = mythread(2)      # 生成mythread对象
>>> t3 = mythread(3)      # 生成mythread对象
>>> t1.start()       # 运行线程t1，实际上是运行run方法
I am  1
>>> t2.start()       # 运行线程t2
I am  2
>>> t3.start()       # 运行线程t3
I am  3

除了通过继承threading.Thread创建类以外，还可以通过使用threading.Thread直接在线程中运行函数。以下代码使用threading.Thread直接创建线程。



>>> import threading         # 导入threading模块
>>> def run(x,y):         # 定义run函数
...   for i in range(x,y):
...   print I
...   
>>> t1 = threading.Thread(target = run,args = (15,20))  # 直接使用Thread附加函数，
  args为函数参数
>>> t1.start()          # 运行线程
15
16
17
18
19
>>> t2 = threading.Thread(target = run,args = (7,11))  # 直接使用Thread附加函数，
  args为函数参数
>>> t2.start()          # 运行线程
7
8
9
10