diff --git a/python/paddle/reader/decorator.py b/python/paddle/reader/decorator.py index 4b1fe94222d35f8c0e4e4cccc364227a3f9509d0..ff64a1a5af2135625636db22d36d0459d3512615 100644 --- a/python/paddle/reader/decorator.py +++ b/python/paddle/reader/decorator.py @@ -325,6 +325,14 @@ def xmap_readers(mapper, reader, process_num, buffer_size, order=False): else: 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