如何修复BrokenProcessPool: concurrent.futures ProcessPoolExecutor的错误

ulimit -u 4096  # 增加用户进程数限制

import concurrent.futures
import logging

logging.basicConfig(level=logging.ERROR)

def task(x):
    try:
        return x * x
    except Exception as e:
        logging.error(f"Task failed with error: {e}")
        raise

with concurrent.futures.ProcessPoolExecutor(max_workers=4) as executor:
    futures = [executor.submit(task, i) for i in range(10)]
    for future in concurrent.futures.as_completed(futures):
        try:
            result = future.result()
        except Exception as e:
            logging.error(f"Result processing failed with error: {e}")

import signal
import sys

def signal_handler(sig, frame):
    print('Signal received, exiting gracefully...')
    sys.exit(0)

signal.signal(signal.SIGTERM, signal_handler)

import multiprocessing

def task(queue):
    queue.put("Task completed")

if __name__ == "__main__":
    queue = multiprocessing.Queue()
    p = multiprocessing.Process(target=task, args=(queue,))
    p.start()
    p.join()
    print(queue.get())