1 files changed, 33 insertions, 0 deletions
diff --git a/src/apscheduler/executors/subprocess.py b/src/apscheduler/executors/subprocess.py
new file mode 100644
index 0000000..e766e71
--- /dev/null
+++ b/src/apscheduler/executors/subprocess.py
@@ -0,0 +1,33 @@
+from __future__ import annotations
+
+from collections.abc import Callable
+from contextlib import AsyncExitStack
+from functools import partial
+from typing import Any
+
+import attrs
+from anyio import CapacityLimiter, to_process
+
+from .._structures import Job
+from ..abc import JobExecutor
+
+
+@attrs.define(eq=False, kw_only=True)
+class ProcessPoolJobExecutor(JobExecutor):
+    """
+    Executes functions in a process pool.
+
+    :param max_workers: the maximum number of worker processes to keep
+    """
+
+    max_workers: int = 40
+    _limiter: CapacityLimiter = attrs.field(init=False)
+
+    async def start(self, exit_stack: AsyncExitStack) -> None:
+        self._limiter = CapacityLimiter(self.max_workers)
+
+    async def run_job(self, func: Callable[..., Any], job: Job) -> Any:
+        wrapped = partial(func, *job.args, **job.kwargs)
+        return await to_process.run_sync(
+            wrapped, cancellable=True, limiter=self._limiter
+        )