python 多线程例子

1 简单的线程同步。
使用Thread对象的Lock和Rlock可以实现简单的线程同步，这两个对象都有acquire方法和release方法，对于那些需要每次只允许一个线程操作的数据，可以将其操作放到acquire和release方法之间。如下：
import threading
import time
class mythread(threading.Thread):
def __init__(self,threadname):
threading.Thread.__init__(self,name=threadname)
def run(self):
global x
lock.acquire()
for i in range(3):
x=x+1
time.sleep(2)
print x
lock.release()
lock=threading.RLock()
t1=[]
for i in range(10):
t=mythread(str(i))
t1.append(t)
x=0
for i in t1:
i.start()
运行结果如下：
>>> 3
6
9
12
15
18
21
24
27
30

>>>
而如果我们把acquire()和release()去掉，结果就不同了：
30303030303030303030
这是因为每个线程执行后在打印出x之前都要休眠2秒钟，所以在这个过程中，每个线程都被执行了，所以等到休眠结束，打印出的X的值自然就是经过多次运算以后的X的值了。
而第一次，我们把全局变量X放到了acquire()和release()之间，python解释器每次回只允许一个线程对x进行操作，只有这个线程结束对其操作并且休眠结束打印出来以后，才允许下一个线程对x操作，所以输出的X是每次递增的，而且用时间也是比较长的。

Python除了用锁和条件变量threading.Condition()来使线程达到同步以外，还可以是用
Queue.Queue()来设置一个队列
Queue队列有2个方法put和get方法put 是把共享数据放入队列，get是取出共享数据
put从队列的尾部放入，get从队列的头部读出。
Queue接受2个参数，一个是队列大小，小于1的队列大小，被认为是无限队列，另一个是同步方式，其中1为阻塞方式，0为触发异常。
其实，用Queue来达到线程同步，是非常简单的，因为Queue本省就是线程安全的。不需要额外的锁和条件变量，看例子：

#coding=utf-8
#file name is maker.py

import threading
import random
import time

class Maker(threading.Thread):

def __init__(self,threadName,shareObject):
threading.Thread.__init__(self,name=threadName)
self.shareObject=shareObject

def run(self):
for i in range(1,11):
time.sleep(random.randrange(1,4))
self.shareObject.put(i)
print "%s threading put %d" %(threading.currentThread().getName(),i)
=========================================================

#coding=utf-8
#file name is user.py

import threading
import time
import random

class User(threading.Thread):

def __init__(self,threadName,shareObject):
threading.Thread.__init__(self,name=threadName)
self.shareObject=shareObject
self.sum=0

def run(self):
for i in range(1,11):
time.sleep(random.randrange(1,4))
tempNum=self.shareObject.get()
print "%s threading get %d" %(threading.currentThread().getName(),tempNum)
self.sum=self.sum+tempNum

def display(self):
print "end sum is %d" %(self.sum)
=======================================================

#coding=utf-8
#file name is test.py

from maker import Maker
from user import User
import Queue

quere=Queue.Queue()

maker1=Maker("maker",quere)
user1=User("user",quere)

user1.start()
maker1.start()

maker1.join()
user1.join()
user1.display()

print "main threading is over!"