Remove duplicate definitions in sub-classes (#8594)

This commit is contained in:
Nikita Sobolev
2022-08-26 18:10:55 +03:00
committed by GitHub
parent d91e5f0eff
commit 0259068ad6
36 changed files with 25 additions and 235 deletions

View File

@@ -137,7 +137,6 @@ class Process(BaseProcess):
class DefaultContext(BaseContext):
Process: ClassVar[type[Process]]
def __init__(self, context: BaseContext) -> None: ...
def set_start_method(self, method: str | None, force: bool = ...) -> None: ...
def get_start_method(self, allow_none: bool = ...) -> str: ...
def get_all_start_methods(self) -> list[str]: ...
if sys.version_info < (3, 8):

View File

@@ -1,5 +1,4 @@
import sys
from multiprocessing.process import BaseProcess
from typing import ClassVar
from . import popen_fork
@@ -15,8 +14,3 @@ if sys.platform != "win32":
class Popen(popen_fork.Popen):
DupFd: ClassVar[type[_DupFd]]
finalizer: Finalize
sentinel: int
def __init__(self, process_obj: BaseProcess) -> None: ...
def duplicate_for_child(self, fd: int) -> int: ...
def poll(self, flag: int = ...) -> int | None: ...

View File

@@ -1,5 +1,4 @@
import sys
from multiprocessing.process import BaseProcess
from typing import ClassVar
from . import popen_fork
@@ -19,6 +18,3 @@ if sys.platform != "win32":
finalizer: Finalize
pid: int # may not exist if _launch raises in second try / except
sentinel: int # may not exist if _launch raises in second try / except
def __init__(self, process_obj: BaseProcess) -> None: ...
def duplicate_for_child(self, fd: int) -> int: ...

View File

@@ -15,18 +15,13 @@ class Queue(queue.Queue[_T]):
def __init__(self, maxsize: int = ..., *, ctx: Any = ...) -> None: ...
def get(self, block: bool = ..., timeout: float | None = ...) -> _T: ...
def put(self, obj: _T, block: bool = ..., timeout: float | None = ...) -> None: ...
def qsize(self) -> int: ...
def empty(self) -> bool: ...
def full(self) -> bool: ...
def put_nowait(self, item: _T) -> None: ...
def get_nowait(self) -> _T: ...
def close(self) -> None: ...
def join_thread(self) -> None: ...
def cancel_join_thread(self) -> None: ...
class JoinableQueue(Queue[_T]):
def task_done(self) -> None: ...
def join(self) -> None: ...
class JoinableQueue(Queue[_T]): ...
class SimpleQueue(Generic[_T]):
def __init__(self, *, ctx: Any = ...) -> None: ...