多处理Consum中的连续字节无效

Question

我在python中打开一些cosumer来多处理一些任务。 有时候，我不知道在什么情况下，我会得到这样的错误：

Process Consumer-9: Traceback (most recent call last):

File "/usr/lib/python2.7/multiprocessing/process.py", line 258, in _bootstrap self.run() File "/home/fon/workspace/acopuzzle/consumer.py", line 26, in run next_task = self.task_queue.get() File "/usr/lib/python2.7/multiprocessing/queues.py", line 117, in get res = self._recv()

UnicodeDecodeError: 'utf8' codec can't decode byte 0xc3 in position 26154714: invalid continuation byte

所以基本上是在/usr/lib/python2.7/multiprocessing中的这一行/队列.py在

self._recv = self._reader.recv

Consumer类的方法运行如下：

^{pr2}$

你有过类似的经历吗？你能给我指出一个好的方向吗？。谢谢