Add multiprocessing.dummy pyi files (#2059)

This commit is contained in:
Martin DeMello
2018-04-18 19:20:01 -07:00
committed by Jelle Zijlstra
parent 8e62a79970
commit 2935017157
4 changed files with 160 additions and 0 deletions

View File

@@ -0,0 +1,53 @@
from typing import Any, Optional, List, Type
import threading
import sys
import weakref
import array
import itertools
from multiprocessing import TimeoutError, cpu_count
from multiprocessing.dummy.connection import Pipe
from threading import Lock, RLock, Semaphore, BoundedSemaphore
from threading import Event
from Queue import Queue
__all__ = ... # type: List[str]
class DummyProcess(threading.Thread):
_children = ... # type: weakref.WeakKeyDictionary
_parent = ... # type: threading.Thread
_pid = ... # type: None
_start_called = ... # type: bool
def __init__(self, group=..., target=..., name=..., args=..., kwargs=...) -> None: ...
@property
def exitcode(self) -> Optional[int]: ...
Process = DummyProcess
# This should be threading._Condition but threading.pyi exports it as Condition
class Condition(threading.Condition):
notify_all = ... # type: Any
class Namespace(object):
def __init__(self, **kwds) -> None: ...
class Value(object):
_typecode = ... # type: Any
_value = ... # type: Any
value = ... # type: Any
def __init__(self, typecode, value, lock=...) -> None: ...
def _get(self) -> Any: ...
def _set(self, value) -> None: ...
JoinableQueue = Queue
def Array(typecode, sequence, lock=...) -> array.array: ...
def Manager() -> Any: ...
def Pool(processes=..., initializer=..., initargs=...) -> Any: ...
def active_children() -> List: ...
def current_process() -> threading.Thread: ...
def freeze_support() -> None: ...
def shutdown() -> None: ...

View File

@@ -0,0 +1,27 @@
from Queue import Queue
from typing import Any, List, Optional, Tuple, Type
__all__ = ... # type: List[str]
families = ... # type: List[None]
class Connection(object):
_in = ... # type: Any
_out = ... # type: Any
recv = ... # type: Any
recv_bytes = ... # type: Any
send = ... # type: Any
send_bytes = ... # type: Any
def __init__(self, _in, _out) -> None: ...
def close(self) -> None: ...
def poll(self, timeout=...) -> Any: ...
class Listener(object):
_backlog_queue = ... # type: Optional[Queue]
address = ... # type: Any
def __init__(self, address=..., family=..., backlog=...) -> None: ...
def accept(self) -> Connection: ...
def close(self) -> None: ...
def Client(address) -> Connection: ...
def Pipe(duplex=...) -> Tuple[Connection, Connection]: ...