import marshal import multiprocessing if __name__ == '__main__': bytes = marshal.dumps({"code": 1}) queue = multiprocessing.Queue(maxsize=1024) queue.put_nowait(bytes) d=queue.get() print(marshal.loads(d))