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

   1 from typing import (\r
   2     Any, Callable, ContextManager, Iterable, Optional, Dict, List,\r
   3     TypeVar, Iterator,\r
   4 )\r
   5 \r
   6 _T = TypeVar('_T', bound=Pool)\r
   7 \r
   8 class AsyncResult():\r
   9     def get(self, timeout: Optional[float] = ...) -> Any: ...\r
  10     def wait(self, timeout: Optional[float] = ...) -> None: ...\r
  11     def ready(self) -> bool: ...\r
  12     def successful(self) -> bool: ...\r
  13 \r
  14 class IMapIterator(Iterable[Any]):\r
  15     def __iter__(self) -> Iterator[Any]: ...\r
  16     def next(self, timeout: Optional[float] = ...) -> Any: ...\r
  17 \r
  18 class Pool(ContextManager[Pool]):\r
  19     def __init__(self, processes: Optional[int] = ...,\r
  20                  initializer: Optional[Callable[..., None]] = ...,\r
  21                  initargs: Iterable[Any] = ...,\r
  22                  maxtasksperchild: Optional[int] = ...) -> None: ...\r
  23     def apply(self,\r
  24               func: Callable[..., Any],\r
  25               args: Iterable[Any] = ...,\r
  26               kwds: Dict[str, Any] = ...) -> Any: ...\r
  27     def apply_async(self,\r
  28                 func: Callable[..., Any],\r
  29                 args: Iterable[Any] = ...,\r
  30                 kwds: Dict[str, Any] = ...,\r
  31                 callback: Optional[Callable[..., None]] = ...) -> AsyncResult: ...\r
  32     def map(self,\r
  33             func: Callable[..., Any],\r
  34             iterable: Iterable[Any] = ...,\r
  35             chunksize: Optional[int] = ...) -> List[Any]: ...\r
  36     def map_async(self, func: Callable[..., Any],\r
  37                   iterable: Iterable[Any] = ...,\r
  38                   chunksize: Optional[int] = ...,\r
  39                   callback: Optional[Callable[..., None]] = ...) -> AsyncResult: ...\r
  40     def imap(self,\r
  41              func: Callable[..., Any],\r
  42              iterable: Iterable[Any] = ...,\r
  43              chunksize: Optional[int] = ...) -> IMapIterator: ...\r
  44     def imap_unordered(self,\r
  45                        func: Callable[..., Any],\r
  46                        iterable: Iterable[Any] = ...,\r
  47                        chunksize: Optional[int] = ...) -> IMapIterator: ...\r
  48     def close(self) -> None: ...\r
  49     def terminate(self) -> None: ...\r
  50     def join(self) -> None: ...\r
  51     def __enter__(self: _T) -> _T: ...\r
  52 \r
  53 class ThreadPool(Pool, ContextManager[ThreadPool]):\r
  54 \r
  55     def __init__(self, processes: Optional[int] = ...,\r
  56                  initializer: Optional[Callable[..., Any]] = ...,\r
  57                  initargs: Iterable[Any] = ...) -> None: ...\r