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

   1 from typing import Any, Optional, List, Type\r
   2 \r
   3 import threading\r
   4 import sys\r
   5 import weakref\r
   6 import array\r
   7 import itertools\r
   8 \r
   9 from multiprocessing import TimeoutError, cpu_count\r
  10 from multiprocessing.dummy.connection import Pipe\r
  11 from threading import Lock, RLock, Semaphore, BoundedSemaphore\r
  12 from threading import Event\r
  13 from Queue import Queue\r
  14 \r
  15 \r
  16 class DummyProcess(threading.Thread):\r
  17     _children = ...  # type: weakref.WeakKeyDictionary\r
  18     _parent = ...  # type: threading.Thread\r
  19     _pid = ...  # type: None\r
  20     _start_called = ...  # type: bool\r
  21     def __init__(self, group=..., target=..., name=..., args=..., kwargs=...) -> None: ...\r
  22     @property\r
  23     def exitcode(self) -> Optional[int]: ...\r
  24 \r
  25 \r
  26 Process = DummyProcess\r
  27 \r
  28 # This should be threading._Condition but threading.pyi exports it as Condition\r
  29 class Condition(threading.Condition):\r
  30     notify_all = ...  # type: Any\r
  31 \r
  32 class Namespace(object):\r
  33     def __init__(self, **kwds) -> None: ...\r
  34 \r
  35 class Value(object):\r
  36     _typecode = ...  # type: Any\r
  37     _value = ...  # type: Any\r
  38     value = ...  # type: Any\r
  39     def __init__(self, typecode, value, lock=...) -> None: ...\r
  40     def _get(self) -> Any: ...\r
  41     def _set(self, value) -> None: ...\r
  42 \r
  43 JoinableQueue = Queue\r
  44 \r
  45 def Array(typecode, sequence, lock=...) -> array.array: ...\r
  46 def Manager() -> Any: ...\r
  47 def Pool(processes=..., initializer=..., initargs=...) -> Any: ...\r
  48 def active_children() -> List: ...\r
  49 def current_process() -> threading.Thread: ...\r
  50 def freeze_support() -> None: ...\r
  51 def shutdown() -> None: ...\r