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

兰竹皋

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

from multiprocessing.pool import ThreadPool
import time

def progress_bar(total, ncols=10, desc='Processing', unit='it'):
    def get_bar(l, n, ncol):
        r = ncol - l - 1
        bar = ''.join(['#' for i in range(l)])
        if l != ncol:
            bar += f'{n}'
        bar += ''.join([' ' for i in range(r)])
        return '|'+bar+'|'

    processing = f'{0:>3d}%'
    bar = get_bar(0, 0, ncols)
    mod = f'{desc}:  {bar} {processing:>4s}'
    print('\r'+mod, end='')

    for i in range(total):
        start_time = time.time()
        # 内容处理
        time.sleep(0.1)

        stop_time = time.time()
        delta_time = stop_time - start_time

        temp = (i+1)/total
        processing = f'{int(temp*100):>3d}%'
        l = int(temp*ncols)
        n = int(temp*ncols*10)%10
        bar = get_bar(l, n, ncols)
        mod = f'{desc}:  {bar} {processing:>4s}  {1/delta_time:.2f}it/s'
        print('\r'+mod, end='')

    print('\n', end='')


def main():
    print('main start')
    pool = ThreadPool(5)
    for i in range(5):
        pool.apply_async(progress_bar, (100,50))
        time.sleep(1)
    pool.close()
    pool.join()
    print('main over')

main()

结果：


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

from multiprocessing.pool import ThreadPool
import time

def progress_bar(total, ncols=10, desc='Processing', unit='it'):
    def get_bar(l, n, ncol):
        r = ncol - l - 1
        bar = ''.join(['#' for i in range(l)])
        if l != ncol:
            bar += f'{n}'
        bar += ''.join([' ' for i in range(r)])
        return '|'+bar+'|'

    processing = f'{0:>3d}%'
    bar = get_bar(0, 0, ncols)
    mod = f'{desc}:  {bar} {processing:>4s}'
    print('\r'+mod, end='')
    
    start_time = time.time()
    
    for i in range(total):
        sub_start_time = time.time()
        # 内容处理
        time.sleep(0.1)

        sub_stop_time = time.time()
        sub_delta_time = sub_stop_time - sub_start_time
        delta_time = sub_stop_time - start_time
        remain_time = (total - i - 1)*sub_delta_time
        
        temp = (i+1)/total
        processing = f'{int(temp*100):>3d}%'
        l = int(temp*ncols)
        n = int(temp*ncols*10)%10
        bar = get_bar(l, n, ncols)
        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]'
        print('\r'+mod, end='')

    print('\n', end='')


def main():
    print('main start')
    pool = ThreadPool(5)
    for i in range(5):
        pool.apply_async(progress_bar, (100,50))
        time.sleep(1)
    pool.close()
    pool.join()
    print('main over')

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
这次注意到了 ^_^