不要在進(jìn)程處理任務(wù)時通過process_id來判斷哪個進(jìn)程應(yīng)該執(zhí)行任務(wù)，因?yàn)椴恢纓ask會被分配到哪個進(jìn)程
<pre>
elif command["type"] == "TEST":
print "testing..."
self.env.type = "test"
print "set env"
if self.process_id == 0:
print "enter test"
right_number = 0
for k in xrange(self.pms.test_epoche_size):
print "testing..." + str(k)
path = self.rollout()
labels = path["labels"]
result = self.env.get_prob_result()
calculate_label = np.argmax(result)
if calculate_label == labels[0]:
right_number += 1
self.result_q.put((right_number / self.pms.test_epoche_size))
else:
print str(self.process_id)
</pre>
這種寫法是錯誤的