Pythonでシンプルにステッド処理

thread.py

import os
import concurrent.futures as confu


def target_func(x):
    return x + 1


def main():
    count = 10
    with confu.ThreadPoolExecutor(max_workers=os.cpu_count()) as executor:
        fs = {executor.submit(target_func, x): x for x in range(count)}
        for f in confu.as_completed(fs):
            print(fs[f], f.result())


if __name__ == "__main__":
    main()


"""
$ python thread.py
2 3
1 2
0 1
3 4
4 5
5 6
6 7
7 8
8 9
9 10
"""