[Python知识库]python多进程

异步多进程

import multiprocessing
import threading
import time
from datetime import datetime
from concurrent.futures import ProcessPoolExecutor


def task(i):
    print(f'task {i} started at {datetime.now()}')
    time.sleep(3)
    print(f'task {i} ended at {datetime.now()}')


def main():
    with ProcessPoolExecutor(max_workers=10) as executor:
        f = executor.submit(task, i=0)
        f = executor.submit(task, i=1)
        f = executor.submit(task, i=2)


if __name__ == '__main__':
    multiprocessing.freeze_support()
    main()
    time.sleep(5)