cyh24 / multicpu Goto Github PK

本人使用Python3.7时发现了两个问题：
问题出现报错出现在： result_queue = cpu_pool.map(_multi_thread, [
[func, self.cpu_num, self.thread_num, job_queue[index[i][0]: index[i][1] + 1], timeout, process_bar, i] for
i in range(len(index))])
解决方法如下：

1. 第一个问题：get_index(job_queue, split_num)方法取整
   each_num = job_num / split_num 这行代码应该是计算平均分配给每个cpu的任务数，此处应该改为each_num = job_num // split_num表示取整;
2. 第二个问题：def _multi_thread(argv)方法中指定线程：
   if getLen(argv[3]) < thread_num: thread_num = argv[3]
   意思为：当分配给该cpu的任务数小于给定的线程数数时，应该根据分配给该cpu的任务数指定线程数，应该改为：
   if getLen(argv[3]) < thread_num: thread_num = len(argv[3])