Python多线程学习-壹-threading

Python多线程学习-threading

 

想学习python多线程，可以直接看官网http://docs.python.org/2/library/threading.html

       Python的文档真心是值得称赞的，不过你如果不想看英文，直接向入门python多线程，本文可以作为你快速入门的捷径。

 

先打开python command端口，输入

 

import threading

 

 Ok，如果没有什么输出，那么就是import成功了。

根据学习的过程并且你如果看过上一篇文章的话，先来下dir命令

 

dir(threading)

BoundedSemaphore
Condition
Event
Lock
RLock
Semaphore
Thread
ThreadError
Timer

 这些是threading包提供的一些多线程模块，看到其中的Thread，有没有感觉很眼熟。

 

这个Thread对于Java的同学来说是个福音，因为使用这个Thread和Java没有什么不同，至少思路一致。

对于threading模块的这些模块，我们后面都会讲到

threading包除了这些模块外，还提供了一些方法，

 

 

threading.enumerate()
  返回当前存活的Thread列表

threading.active_count()
threading.activeCount()
  返回当前的依然存活的Thread数量，实际上就是enumerate()返回的长度

threading.current_thread()
threading.current_Thread()
  返回当前的线程，根据调用线程的不同返回不同值

threading.local
  表示thread-local量，Thread-Local数据是跟Thread相关的

 上面这些都是和threading包的内容，实际是保存了当前main thread的宏观信息，明白这个就好。

 

下面我们来学习Thread模块，按照惯例，执行dir命令

 

dir(threading.Thread)

daemon
getName
ident
isAlive
isDaemon
is_alive
join
name
run
setDaemon
setName
start

 

 

可以看到，Thread有几个重要的属性，daemon、name、alive、ident

daemon：这个参数很关键。在调用start前设置改值，默认主线程创建的子线程都是False，表示主线程必须等子线程完成才能退出；如果为True的话，主线程退出导致子线程立即退出，根据自己的应用场景设置合适的True或者False。

name：thread name

alive：ture or false

ident：identity

      看到run和join方法了吗？这个有没有很熟悉。下面我们来看下通过继承threading.Thread 来创建线程的方法。

 

#!/usr/bin/python

import threading
import time

class my_thread(threading.Thread):
  def __init__(self,threadname,interval):
    threading.Thread.__init__(self,name=threadname)
    self.interval=interval

  def run(self):
    print dir(self)
    for i in range(10):
      print self.getName,i
      time.sleep(self.interval)


if __name__ == "__main__":
  mythread=my_thread("thread one",3)
  mythread2=my_thread("thread two",5)
  mythread.start()
  mythread2.start()

 

下面我们再看下用另一种方法来创建线程的方法

 

 

#!/usr/bin/python

import threading
import time

def run(interval):
  for i in range(5):
    print threading.current_thread().getName(),i
    time.sleep(interval)


if __name__ == "__main__":
  for i in range(3):
    threading.Thread(target=run,args=[5],name='thread-' + str(i)).start()

 

对于这种方法创建的线程，我们看下init函数：

 

def __init__(self, group=None, target=None, name=None, args=(), kwargs={})
　　group：预留
　　target：是一个可调用对象（也称为活动[activity]），在线程启动后执行；
　　name：是线程的名字。默认值为“Thread-N“，N是一个数字。
　　args和kwargs：表示调用target时的参数列表和关键字参数。

 

看使用方法，应该是使用第一种更为方便

我们先看下daemon的用法：

 

import threading
import datetime
from time import sleep
import sys

class threadclass(threading.Thread):
  def run(self):
    print self.daemon
    for i in range(10):
      now=datetime.datetime.now()
      print "%s says hello world at  time:%s" %(self.getName(),now)
      sleep(1)

if __name__ == "__main__":
  t=threadclass();
  t.daemon=True
  t.start()
  sleep(5)
  sys.exit(0)

 

 

可以看到执行了五次后就退出了，主线程推出子线程也就退出了。

可以再将t.daemon=True注掉后再运行一下，对比下结果。

 

关于join的用法，如果在主线程中调用这个方法，会等子线程执行完成后主线程才会退出来。

这个join用法和daemon参数是有冲突的，不过一般不会同时设置daemon参数和调用join方法

有了Thread结构，后面的工作就很简单啦。

下面我们再看下threading.Timer的用法。

 

#!/usr/bin/python

import threading
import time

def run():
  print "hello word";

if __name__ == "__main__":
  t=threading.Timer(5.0,run)
  t.start()

 

 

Timer的用法比较简单，就是设定一个时间点interval，等到时间间隔到了后，执行function

并没有想你想象的那么大的功能，如Java的Timer、Quartz的Scheduler等。

这个Timer的功能从初始化函数可以看出来：

 

 

def __init__(self, interval, function, args=[], kwargs={}):
     interval：时间间隔
     function：执行函数
     args、kwargs：函数执行参数

 

 

 

本节我们学习了Thread、Timer两个模型，下节课我们学习别的内容