loky/process_executor.py
def _ensure_executor_running(self):
        """ensures all workers and management thread are running
        """
        with self._processes_management_lock:
            if len(self._processes) != self._max_workers:
                self._adjust_process_count()
            self._start_queue_management_thread()
def _ensure_executor_running(self):
        with self._processes_management_lock:
            if len(self._processes) != self._max_workers:
                self._adjust_process_count()
            self._start_queue_management_thread()
def _ensure_executor_running ( self ) : with self . _processes_management_lock : if len ( self . _processes ) != self . _max_workers : self . _adjust_process_count ( ) self . _start_queue_management_thread ( )
ensures all workers and management thread are running
ensures all workers and management thread are running