Python 进程池使用示例

#!/usr/bin/env python3
# coding: utf-8

import multiprocessing
import time
import datetime


def executor(lock, test_list, test_value, e_id):
    time.sleep(1)
    try:
        lock.acquire()
        test_list.append(e_id)
        test_value.value += 1
    except Exception as e:
        print(e)
        raise e
    finally:
        lock.release()

    print(f"executor id: {e_id}, test_list: {test_list}, time: {datetime.datetime.now()}")


def main():
    pool = multiprocessing.Pool(processes=4)
    manager = multiprocessing.Manager()
    lock = manager.Lock()
    test_list = manager.list()
    test_value = manager.Value(int, 0)

    for i in range(20):
        pool.apply_async(executor, args=(lock, test_list, test_value, i))

    pool.close()
    pool.join()
    test_list.sort()
    print(f"test_list: {test_list}")
    print(f"test_value: {test_value.value}")


if __name__ == '__main__':
    main()