.config/coc/extensions/coc-python-data/languageServer.0.5.59/Typeshed/stdlib/2/multiprocessing/__init__.pyi

   1 from typing import Any, Callable, Optional, TypeVar, Iterable\r
   2 \r
   3 from multiprocessing import pool\r
   4 from multiprocessing.process import Process as Process, current_process as current_process, active_children as active_children\r
   5 from multiprocessing.util import SUBDEBUG as SUBDEBUG, SUBWARNING as SUBWARNING\r
   6 from Queue import Queue as _BaseQueue\r
   7 \r
   8 class ProcessError(Exception): ...\r
   9 class BufferTooShort(ProcessError): ...\r
  10 class TimeoutError(ProcessError): ...\r
  11 class AuthenticationError(ProcessError): ...\r
  12 \r
  13 _T = TypeVar('_T')\r
  14 \r
  15 class Queue(_BaseQueue[_T]):\r
  16     def __init__(self, maxsize: int = ...) -> None: ...\r
  17     def get(self, block: bool = ..., timeout: Optional[float] = ...) -> _T: ...\r
  18     def put(self, item: _T, block: bool = ..., timeout: Optional[float] = ...) -> None: ...\r
  19     def qsize(self) -> int: ...\r
  20     def empty(self) -> bool: ...\r
  21     def full(self) -> bool: ...\r
  22     def put_nowait(self, item: _T) -> None: ...\r
  23     def get_nowait(self) -> _T: ...\r
  24     def close(self) -> None: ...\r
  25     def join_thread(self) -> None: ...\r
  26     def cancel_join_thread(self) -> None: ...\r
  27 \r
  28 def Manager(): ...\r
  29 def Pipe(duplex=True): ...\r
  30 def cpu_count() -> int: ...\r
  31 def freeze_support(): ...\r
  32 def get_logger(): ...\r
  33 def log_to_stderr(level=None): ...\r
  34 def allow_connection_pickling(): ...\r
  35 def Lock(): ...\r
  36 def RLock(): ...\r
  37 def Condition(lock=None): ...\r
  38 def Semaphore(value=1): ...\r
  39 def BoundedSemaphore(value=1): ...\r
  40 def Event(): ...\r
  41 def JoinableQueue(maxsize=0): ...\r
  42 def RawValue(typecode_or_type, *args): ...\r
  43 def RawArray(typecode_or_type, size_or_initializer): ...\r
  44 def Value(typecode_or_type, *args, **kwds): ...\r
  45 def Array(typecode_or_type, size_or_initializer, **kwds): ...\r
  46 \r
  47 def Pool(processes: Optional[int] = ...,\r
  48          initializer: Optional[Callable[..., Any]] = ...,\r
  49          initargs: Iterable[Any] = ...,\r
  50          maxtasksperchild: Optional[int] = ...) -> pool.Pool: ...\r