在jupyter notebook中运行代码时使用BrokenProcessPool

import psutil
print(psutil.virtual_memory())
print(psutil.cpu_percent(interval=1))

from concurrent.futures import ProcessPoolExecutor
import logging

logging.basicConfig(level=logging.ERROR)

def task(x):
    try:
        # Your code here
        return x * x
    except Exception as e:
        logging.error(f"Error in task: {e}")
        raise

with ProcessPoolExecutor() as executor:
    results = list(executor.map(task, range(10)))

from concurrent.futures import ProcessPoolExecutor

max_workers = min(32, (os.cpu_count() or 1) + 4)
with ProcessPoolExecutor(max_workers=max_workers) as executor:
    results = list(executor.map(task, range(10)))

import signal
import sys

def handle_sigint(signum, frame):
    print("Received SIGINT, exiting gracefully...")
    sys.exit(0)

signal.signal(signal.SIGINT, handle_sigint)

from concurrent.futures import ProcessPoolExecutor
import logging

logging.basicConfig(level=logging.ERROR)

def square(x):
    try:
        return x * x
    except Exception as e:
        logging.error(f"Error in square function: {e}")
        raise

try:
    with ProcessPoolExecutor() as executor:
        results = list(executor.map(square, range(10)))
        print(results)
except Exception as e:
    logging.error(f"Error in ProcessPoolExecutor: {e}")