Move all process functions to new threadpool executor.

Author: ayjayt

choreographer/browser_async.py

@@ -46,6 +46,9 @@ async def close(self) -> None:
 class Browser(Target):
     """`Browser` is the async implementation of `Browser`."""
 
+    subprocess: subprocess.Popen[bytes] | subprocess.Popen[str]
+    """A reference to the `Popen` object."""
+
     tabs: MutableMapping[str, Tab]
     """A mapping by target_id of all the targets which are open tabs."""
     targets: MutableMapping[str, Target]
@@ -96,7 +99,7 @@ def __init__(
         """
         _logger.debug("Attempting to open new browser.")
 
-        self._check_closed_executor = _manual_thread_pool.ManualThreadExecutor(
+        self._process_executor = _manual_thread_pool.ManualThreadExecutor(
             max_workers=3,
             name="checking_close",
         )
@@ -144,7 +147,10 @@ def run() -> subprocess.Popen[bytes] | subprocess.Popen[str]:  # depends on args
 
         _logger.debug("Trying to open browser.")
         loop = asyncio.get_running_loop()
-        self.subprocess = await loop.run_in_executor(None, run)
+        self.subprocess = await loop.run_in_executor(
+            self._process_executor,
+            run,
+        )
 
         super().__init__("0", self._broker)
         self._add_session(Session("", self._broker))
@@ -194,7 +200,7 @@ async def _is_closed(self, wait: int | None = 0) -> bool:
                 loop = asyncio.get_running_loop()
 
                 await loop.run_in_executor(
-                    self._check_closed_executor,
+                    self._process_executor,
                     self.subprocess.wait,
                     wait,
                 )
@@ -246,6 +252,8 @@ async def close(self) -> None:
             self._watch_dog_task.cancel()
         if not self._release_lock():
             return
+        # it can never be mid open here, because all of these must
+        # run on the same thread. Do not push open or close to threads.
         try:
             _logger.debug("Starting browser close methods.")
             await self._close()
@@ -263,7 +271,7 @@ async def close(self) -> None:
         _logger.debug("Browser channel closed.")
         self._browser_impl.clean()  # os blocky/hangy across networks
         _logger.debug("Browser implementation cleaned up.")
-        self._check_closed_executor.shutdown(wait=False, cancel_futures=True)
+        self._process_executor.shutdown(wait=False, cancel_futures=True)
 
     async def __aexit__(
         self,