mirrors/cpython
1
0
Fork 0
mirror of https://github.com/python/cpython.git synced 2025-09-26 18:29:57 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 10

Issue #18934: Use poll/select-based selectors for multiprocessing.Connection,

Browse source 
to avoid one extra FD per Connection.
This commit is contained in:
Charles-François Natali 2013-09-08 11:30:53 +02:00
parent 742d8716ff
commit 45e255167e
1 changed files with 9 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

10
Lib/multiprocessing/connection.py
View file

@ -878,13 +878,21 @@ else:
import selectors import selectors
# poll/select have the advantage of not requiring any extra file
# descriptor, contrarily to epoll/kqueue (also, they require a single
# syscall).
if hasattr(selectors, 'PollSelector'):
_WaitSelector = selectors.PollSelector
else:
_WaitSelector = selectors.SelectSelector
def wait(object_list, timeout=None): def wait(object_list, timeout=None):
''' '''
Wait till an object in object_list is ready/readable. Wait till an object in object_list is ready/readable.
Returns list of those objects in object_list which are ready/readable. Returns list of those objects in object_list which are ready/readable.
''' '''
with selectors.DefaultSelector() as selector: with _WaitSelector() as selector:
for obj in object_list: for obj in object_list:
selector.register(obj, selectors.EVENT_READ) selector.register(obj, selectors.EVENT_READ)