我的应用程序通过套接字从 Web 服务器接收要执行的作业。在应用程序上运行作业的那一刻，我只能再向应用程序发送 2 条消息，然后它就不会再收到了。
def handlemsg (self, data):
self.sendmsg (cPickle.dumps('received')) # send web server notification received
data = cPickle.loads(data)
print data
# Terminate a Job
if data[-1] == 'terminate':
self.terminate(data[0])
# Check if app is Available
elif data[-1] == 'prod':
pass
# Run Job
else:
supply = supply_thread(data, self.app)
self.supplies[data['job_name']] = supply
supply.daemon = True
supply.start()
我可以向服务器发送尽可能多的产品。但是，一旦我发送了一个激活线程的作业，那么响应就会变得有限。出于某种原因，它允许我在作业运行时再发送两个 prods……但在那之后打印消息将不会出现，它只会继续工作。
有任何想法吗？谢谢