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

Set the FDs non-blocking in the selectors example.

Browse source
This commit is contained in:
Charles-François Natali 2013-11-29 18:52:51 +01:00
parent de3a1363a9
commit a9f90bc602
1 changed files with 12 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

21
Doc/library/selectors.rst
View file

@ -214,26 +214,29 @@ Examples of selector usage::
>>> import selectors >>> import selectors
>>> import socket >>> import socket
>>> >>>
>>> s = selectors.DefaultSelector() >>> s = selectors.DefaultSelector()
>>> r, w = socket.socketpair() >>> r, w = socket.socketpair()
>>> >>>
>>> r.setblocking(False)
>>> w.setblocking(False)
>>>
>>> s.register(r, selectors.EVENT_READ) >>> s.register(r, selectors.EVENT_READ)
SelectorKey(fileobj=<socket.socket fd=4, family=1, type=1, proto=0>, fd=4, events=1, data=None) SelectorKey(fileobj=<socket.socket fd=4, family=AddressFamily.AF_UNIX, type=2049, proto=0>, fd=4, events=1, data=None)
>>> s.register(w, selectors.EVENT_WRITE) >>> s.register(w, selectors.EVENT_WRITE)
SelectorKey(fileobj=<socket.socket fd=5, family=1, type=1, proto=0>, fd=5, events=2, data=None) SelectorKey(fileobj=<socket.socket fd=5, family=AddressFamily.AF_UNIX, type=2049, proto=0>, fd=5, events=2, data=None)
>>> >>>
>>> print(s.select()) >>> print(s.select())
[(SelectorKey(fileobj=<socket.socket fd=5, family=1, type=1, proto=0>, fd=5, events=2, data=None), 2)] [(SelectorKey(fileobj=<socket.socket fd=5, family=AddressFamily.AF_UNIX, type=2049, proto=0>, fd=5, events=2, data=None), 2)]
>>> >>>
>>> for key, events in s.select(): >>> for key, events in s.select():
... if events & selectors.EVENT_WRITE: ... if events & selectors.EVENT_WRITE:
... key.fileobj.send(b'spam') ... key.fileobj.send(b'spam')
... ...
4 4
>>> for key, events in s.select(): >>> for key, events in s.select():
... if events & selectors.EVENT_READ: ... if events & selectors.EVENT_READ:
... print(key.fileobj.recv(1024)) ... print(key.fileobj.recv(1024))
... ...
b'spam' b'spam'
>>> s.close() >>> s.close()