[已解决]求助，好奇怪的，关于多线程中循环不执行问题。。。

兰竹皋

读者好，这个很奇怪的问题，如下代码，可以正常运行：

1. from multiprocessing.pool import ThreadPool
   
2. import time
   
3. 
   
4. def progress_bar(total, ncols=10, desc='Processing', unit='it'):
   
5.     def get_bar(l, n, ncol):
   
6.         r = ncol - l - 1
   
7.         bar = ''.join(['#' for i in range(l)])
   
8.         if l != ncol:
   
9.             bar += f'{n}'
   
10.         bar += ''.join([' ' for i in range(r)])
    
11.         return '|'+bar+'|'
    
12. 
    
13.     processing = f'{0:>3d}%'
    
14.     bar = get_bar(0, 0, ncols)
    
15.     mod = f'{desc}:  {bar} {processing:>4s}'
    
16.     print('\r'+mod, end='')
    
17. 
    
18.     for i in range(total):
    
19.         start_time = time.time()
    
20.         # 内容处理
    
21.         time.sleep(0.1)
    
22. 
    
23.         stop_time = time.time()
    
24.         delta_time = stop_time - start_time
    
25. 
    
26.         temp = (i+1)/total
    
27.         processing = f'{int(temp*100):>3d}%'
    
28.         l = int(temp*ncols)
    
29.         n = int(temp*ncols*10)%10
    
30.         bar = get_bar(l, n, ncols)
    
31.         mod = f'{desc}:  {bar} {processing:>4s}  {1/delta_time:.2f}it/s'
    
32.         print('\r'+mod, end='')
    
33. 
    
34.     print('\n', end='')
    
35. 
    
36. 
    
37. def main():
    
38.     print('main start')
    
39.     pool = ThreadPool(5)
    
40.     for i in range(5):
    
41.         pool.apply_async(progress_bar, (100,50))
    
42.         time.sleep(1)
    
43.     pool.close()
    
44.     pool.join()
    
45.     print('main over')
    
46. 
    
47. main()
    

复制代码

结果：


但在改了progress函数最下方mod字符串后，就不能运行了。。。。为什么？没有报错，就是循环没有运行。。。

1. from multiprocessing.pool import ThreadPool
   
2. import time
   
3. 
   
4. def progress_bar(total, ncols=10, desc='Processing', unit='it'):
   
5.     def get_bar(l, n, ncol):
   
6.         r = ncol - l - 1
   
7.         bar = ''.join(['#' for i in range(l)])
   
8.         if l != ncol:
   
9.             bar += f'{n}'
   
10.         bar += ''.join([' ' for i in range(r)])
    
11.         return '|'+bar+'|'
    
12. 
    
13.     processing = f'{0:>3d}%'
    
14.     bar = get_bar(0, 0, ncols)
    
15.     mod = f'{desc}:  {bar} {processing:>4s}'
    
16.     print('\r'+mod, end='')
    
17.    
    
18.     start_time = time.time()
    
19.    
    
20.     for i in range(total):
    
21.         sub_start_time = time.time()
    
22.         # 内容处理
    
23.         time.sleep(0.1)
    
24. 
    
25.         sub_stop_time = time.time()
    
26.         sub_delta_time = sub_stop_time - sub_start_time
    
27.         delta_time = sub_stop_time - start_time
    
28.         remain_time = (total - i - 1)*sub_delta_time
    
29.         
    
30.         temp = (i+1)/total
    
31.         processing = f'{int(temp*100):>3d}%'
    
32.         l = int(temp*ncols)
    
33.         n = int(temp*ncols*10)%10
    
34.         bar = get_bar(l, n, ncols)
    
35.         mod = f'{desc}:  {bar} {processing:>4s}  [{delta_time//60:0>2d}:{delta_time%60:0>2d}<{remain_time//60:0>2d}:{remain_time%60:0>2d}, {1/sub_delta_time:.2f}it/s]'
    
36.         print('\r'+mod, end='')
    
37. 
    
38.     print('\n', end='')
    
39. 
    
40. 
    
41. def main():
    
42.     print('main start')
    
43.     pool = ThreadPool(5)
    
44.     for i in range(5):
    
45.         pool.apply_async(progress_bar, (100,50))
    
46.         time.sleep(1)
    
47.     pool.close()
    
48.     pool.join()
    
49.     print('main over')
    
50. 
    
51. main()
    

复制代码

结果：


希望得到解惑，谢谢。。。

最佳答案

月排行榜 / 总排行榜

gonff

2020-11-18 18:49:39

试了一下，主要原因有两个：
其一是remain_time和sub_delta_time都没有定义；（如果你其他语句里定义了，那就没这个问题）
其二是d不支持浮点型。例如
>>> f'{0.1:>2d}'
Traceback (most recent call last):
  File "<pyshell#0>", line 1, in <module>
    f'{0.1:>2d}'
ValueError: Unknown format code 'd' for object of type 'float'
>>> f'{0.1:>.2f}'
'0.10'

这两个错误导致，for i in range(total)内语句每次执行到mod这里就跳出。不会显示。最终显示的只有初始化用的那个进度条。
我改成了这样：
mod = f'{desc}:  {bar} {processing:>4s}    [{delta_time//60:.2f}<{delta_time%60:>.2f}{1/delta_time:.2f}it/s]'
可以显示。你可以再改一下变成你需要的。

另外如果你要求整数的话就int作用一下  
{int(delta_time//60):>2d}

跳转到最佳答案楼层

兰竹皋

武婵冰 发表于 2020-11-17 12:13
**** 作者被禁止或删除 内容自动屏蔽 ****

？？

gonff

试了一下，主要原因有两个：
其一是remain_time和sub_delta_time都没有定义；（如果你其他语句里定义了，那就没这个问题）
其二是d不支持浮点型。例如
>>> f'{0.1:>2d}'
Traceback (most recent call last):
  File "<pyshell#0>", line 1, in <module>
    f'{0.1:>2d}'
ValueError: Unknown format code 'd' for object of type 'float'
>>> f'{0.1:>.2f}'
'0.10'

这两个错误导致，for i in range(total)内语句每次执行到mod这里就跳出。不会显示。最终显示的只有初始化用的那个进度条。
我改成了这样：
mod = f'{desc}:  {bar} {processing:>4s}    [{delta_time//60:.2f}<{delta_time%60:>.2f}{1/delta_time:.2f}it/s]'
可以显示。你可以再改一下变成你需要的。

另外如果你要求整数的话就int作用一下  
{int(delta_time//60):>2d}

兰竹皋

gonff 发表于 2020-11-18 18:49
试了一下，主要原因有两个：
其一是remain_time和sub_delta_time都没有定义；（如果你其他语句里定义了， ...

谢谢你，
我一直以为，比如： 11.23//10=1,  11.23%10 =1， 会自动华为int
这次注意到了 ^_^