import threading,time
event=threading.Event()
def foo()
        while not event.is_set():
            print('sleep to wait.....')
            event.wait(2)#在这里休息两秒阻塞主
        print(' connent to redis server' , n)

for i in range(10):
    t=threading.Thread(target=foo,args=(i,))
    t.start

print('redis sever started')
time.sleep(10000)
print('tedis start access.......')
event.set()#在这里修改成True

创建一个“队列”对象

import Queue
q = Queue.Queue(maxsize = 10)
Queue.Queue类即是一个队列的同步实现。队列长度可为无限或者有限。可通过Queue的构造函数的可选参数
maxsize来设定队列长度。如果maxsize小于0就表示队列长度无限。

将一个值放入队列中（如队）
q.put(10)
调用队列对象的put()方法在队尾插入一个项目。put()有两个参数，第一个item为必需的，为插入项目的值；
第二个block为可选参数，默认为
1。如果队列当前为空且block为1，put()方法就使调用线程暂停,直到空出一个数据单元。如果block为0，
put方法将引发Full异常。

将一个值从队列中取出（出队）
q.get()
调用队列对象的get()方法从队头删除并返回一个项目。可选参数为block，默认为True。如果队列为空且
block为True，get()就使调用线程暂停，直至有项目可用。如果队列为空且block为False，队列将引发Empty异常。

此包中的常用方法(q = Queue.Queue()):

q.qsize() 返回队列的大小
q.empty() 如果队列为空，返回True,反之False
q.full() 如果队列满了，返回True,反之False
q.full 与 maxsize 大小对应
q.get([block[, timeout]]) 获取队列，timeout等待时间
q.get_nowait() 相当q.get(False)非阻塞 
q.put(item) 写入队列，timeout等待时间
q.put_nowait(item) 相当q.put(item, False)
q.task_done() 在完成一项工作之后，q.task_done() 函数向任务已经完成的队列发送一个信号
q.join() 实际上意味着等到队列为空，再执行别的操作

import queue
q=queue.Queue()#FIFO先进先出

##进队
q.put(11)
q.put('hellow')

##出队
print(q.get())
print(q.get())

join() 阻塞进程，直到所有任务完成，需要配合另一个方法task_done。

    def join(self):
     with self.all_tasks_done:
      while self.unfinished_tasks:
       self.all_tasks_done.wait()

task_done() 表示某个任务完成。每一条get语句后需要一条task_done。也就是说上面出现了几次put下面需要跟随几个task_done()

import queue,threading,time
q=queue.Queue()
def foo():
    q.put(123)
    q.put(234)
    q.put(345)
    q.join()
    print('end foo')
    q.put_nowait(555)#假如说不添加join的话就会产生报错

def bar():
    print(q.get())
    q.task_done()
    print(q.get())
    q.task_done()
    print(q.get())
    time.sleep()
    q.task_done()
   
t1=threading.Thread(target=foo,args=())
t1.start()
t2=threading.Thraed(target=bar,args=())
t2.start()

结果就是不报错，
打印出
123
234
345

import queue,threading

q=queue.LifoQueue()#FILO的方式

q.put(11)
q.put(12)
q.put(13)

while not q.empty():#如果列表不为空empty就是false
    print(q.get())



打印结果：：

13
12
11

import queue
q=queue.PriorityQueue()
q.put([1,'hello1'])#设置[优先级,内容]
q.put([5,'hello5'])
q.put([2,'hello2'])
q.put([1,'111111'])
while not q.empty():
        print(q.get())

打印的结果
[1, '11111']
[1, 'hello1']
[2, 'hello2']
[5, 'hello5']

import queue,threading,random,time
q=queue.Queue(5)
def foo():
    while True:
        s=random.randint(1,99)
        q.put(s)
　　　　　print('make baozi%s' %(s,))
        time.sleep(3)
def eat():
    while True:
        print('eat baozi%s' %(q.get()))
        time.sleep(2)
for i in range(10):
    t=threading.Thread(target=foo,args=())
    t.start()
for i in range(50):
    t=threading.Thread(target=eat,args=())
    t.start()