提交 ce4ddd78 编写于 作者: M minqiyang

Add debug info

上级 19639e31
...@@ -325,6 +325,14 @@ def xmap_readers(mapper, reader, process_num, buffer_size, order=False): ...@@ -325,6 +325,14 @@ def xmap_readers(mapper, reader, process_num, buffer_size, order=False):
else: else:
yield sample yield sample
assert finish == process_num
for w in workers:
print('join worker: ', w)
print('join worker: ', w.is_alive())
w.join()
print('join worker: ', w.is_alive())
del workers
return xreader return xreader
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册