私のアプリは、ソケットを介して 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()
サーバーに好きなだけ製品を送信できます。しかし、スレッドをアクティブにするジョブを送信すると、応答が制限されます。何らかの理由で、ジョブの実行中にさらに 2 つの prod を送信できるようになります...しかし、その後、印刷メッセージは表示されず、そのまま動作し続けます。
何か案は？ありがとう