python多线程和队列的实现

需求

需求很简单就是需要并发的去做一个事情，能够实现多线程和队列的控制

代码

#!/usr/bin/env python
# -*- coding: UTF-8 -*-
import commands
import random

import threading
import Queue

myqueue = Queue.Queue(maxsize = 10)

for object in range(100):
    def do_top(object,myqueue):
        myqueue.put(object)
        print object
        mysleep=random.randint(1, 10)
        pg_info_get  = commands.getoutput('sleep %d  2>/dev/null' %mysleep)
        myqueue.get(object)
        myqueue.task_done()

    t=threading.Thread(target=do_top,args=(object,myqueue))
    t.start()

示例的代码很简单，就是随机的做sleep，做完了就马上有下一个接着去做，设置了一个队列的大小伟10

通过ps -ef|grep sleep可以看到确实控制在10个了