Ich möchte einen Web-Service schreiben, der die Anfrage im Hintergrund verarbeitet. Der Dienst stellt die Anfrage in eine Warteschlange und antwortet dem Kunden sofort.Python Tornado Web-Service für lang laufenden Prozess
Mein Problem im folgenden Code ist, dass While-Schleife in BackgroundThread(). Run() Funktion nicht funktioniert.
While-Schleife in der Methode BackgroundThread.run() verhält sich nicht wie infinite.It nur einmal in die While-Schleife gehen.
Vielen Dank.
Code:
class BackgroundThread(threading.Thread):
def __init__(self):
threading.Thread.__init__(self)
def run(self):
global queue
while True:
item = queue.get()
if item is not None:
#long running process
time.sleep(random.randint(10, 100)/1000.0)
print "task", item, "finished"
queue = Queue.Queue()
class MyHandler(tornado.web.RequestHandler):
@gen.coroutine
def get(self):
global queue
self.write('OK')
self.finish()
filePath = self.get_arguments("filePath")
queue.put(filePath)
print queue.qsize()
if __name__=='__main__':
try:
BackgroundThread().start()
BackgroundThread().start()
app = tornado.web.Application([(r'/', MyHandler)])
print("server opened on port : 8000")
server = tornado.httpserver.HTTPServer(app)
server.bind(8000)
server.start(4) # Specify number of subprocesses
tornado.ioloop.IOLoop.current().start()
except KeyboardInterrupt:
print '^C received, shutting down the web server'
sys.exit(1)
Was meinst du mit „Worker.run() Funktion funktioniert nicht“? – praveen
Ich habe Worker zu BackgroundThread bearbeitet. Und Endlosschleife in Run-Funktion verhält sich nicht wie unendlich. Es geht nur einmal in die While-Schleife. –