1)創建一個Queue.Queue對象

2)根據您的喜好制作盡可能多的“工作”線程,從Queue.Queue讀取

3)將作業提供給Queue.Queue

工作線程將按照它們放置的順序讀取Queue.Queue

從文件中讀取行并將它們放入Queue.Queue的示例

import sys

import urllib2

import urllib

from Queue import Queue

import threading

import re

THEEND = "TERMINATION-NOW-THE-END"

#read from file into Queue.Queue asynchronously

class QueueFile(threading.Thread):

def run(self):

if not(isinstance(self.myq, Queue)):

print "Queue not set to a Queue"

sys.exit(1)

h = open(self.f, 'r')

for l in h:

self.myq.put(l.strip()) # this will block if the queue is full

self.myq.put(THEEND)

def set_queue(self, q):

self.myq = q

def set_file(self, f):

self.f = f

了解工作線程可能是什么樣的(僅限示例)

class myWorker(threading.Thread):

def run(self):

while(running):

try:

data = self.q.get() # read from fifo

req = urllib2.Request("http://192.168.1.10/url/path")

req.add_data(urllib.urlencode(data))

h1 = urllib2.urlopen(req, timeout=10)

res = h1.read()

assert(len(res) > 80)

except urllib2.HTTPError, e:

print e

except urllib2.URLError, e:

print "done %d reqs " % n

print e

sys.exit()

要使對象基于threading.Thread go,創建對象然后在實例上調用“start”