Fix hang bug in parallel_map.py when multiprocessing mode used and some consumer exit abnormally (#106)