select — Waiting for I/O completion¶
This module provides access to the select() and poll() functions
available in most operating systems, devpoll() available on
Solaris and derivatives, epoll() available on Linux 2.5+ and
kqueue() available on most BSD.
Note that on Windows, it only works for sockets; on other operating systems,
it also works for other file types (in particular, on Unix, it works on pipes).
It cannot be used on regular files to determine whether a file has grown since
it was last read.
Примітка
Модуль selectors забезпечує високорівневе й ефективне мультиплексування вводу/виводу, побудоване на основі примітивів модуля select. Замість цього користувачам рекомендується використовувати модуль selectors, якщо вони не бажають точного контролю над використовуваними примітивами рівня ОС.
Availability: not WASI.
This module does not work or is not available on WebAssembly. See WebAssembly platforms for more information.
Модуль визначає наступне:
- select.devpoll()¶
(Підтримується лише в Solaris і похідних.) Повертає об’єкт опитування
/dev/poll; дивіться розділ /dev/poll Опитування об’єктів нижче щодо методів, які підтримуються об’єктами devpoll.devpoll()objects are linked to the number of file descriptors allowed at the time of instantiation. If your program reduces this value,devpoll()will fail. If your program increases this value,devpoll()may return an incomplete list of active file descriptors.Новий файловий дескриптор не успадковується.
Added in version 3.3.
Змінено в версії 3.4: Новий файловий дескриптор тепер не успадковується.
- select.epoll(sizehint=-1, flags=0)¶
(Підтримується лише в Linux 2.5.44 і новіших версіях.) Повертає об’єкт опитування краю, який можна використовувати як інтерфейс Edge або Level Triggered для подій введення/виведення.
sizehint informs epoll about the expected number of events to be registered. It must be positive, or
-1to use the default. It is only used on older systems whereepoll_create1()is not available; otherwise it has no effect (though its value is still checked).flags застаріло та повністю ігнорується. Однак, коли надається, його значення має бути
0абоselect.EPOLL_CLOEXEC, інакшеOSErrorвикликається.Перегляньте розділ Опитування (epoll) об’єктів тригера краю та рівня нижче, щоб дізнатися про методи, які підтримуються об’єктами електронного опитування.
Об’єкти
epollпідтримують протокол керування контекстом: при використанні в операторіwithновий дескриптор файлу автоматично закривається в кінці блоку.Новий файловий дескриптор не успадковується.
Змінено в версії 3.3: Додано параметр flags.
Змінено в версії 3.4: Додано підтримку оператора
with. Новий файловий дескриптор тепер не успадковується.Застаріло починаючи з версії 3.4: Параметр flags.
select.EPOLL_CLOEXECзараз використовується за умовчанням. Використовуйтеos.set_inheritable(), щоб зробити дескриптор файлу спадковим.
- select.poll()¶
(Підтримується не всіма операційними системами.) Повертає об’єкт опитування, який підтримує реєстрацію та скасування реєстрації дескрипторів файлів, а потім опитування їх для подій введення/виведення; дивіться розділ Об’єкти опитування нижче щодо методів, які підтримуються об’єктами опитування.
- select.kqueue()¶
(Підтримується лише в BSD.) Повертає об’єкт черги ядра; перегляньте розділ Об’єкти Kqueue нижче, щоб дізнатися про методи, які підтримуються об’єктами kqueue.
Новий файловий дескриптор не успадковується.
Змінено в версії 3.4: Новий файловий дескриптор тепер не успадковується.
- select.kevent(ident, filter=KQ_FILTER_READ, flags=KQ_EV_ADD, fflags=0, data=0, udata=0)¶
(Підтримується лише в BSD.) Повертає об’єкт події ядра; дивіться розділ Об’єкти Kevent нижче щодо методів, які підтримуються об’єктами kevent.
- select.select(rlist, wlist, xlist[, timeout])¶
This is a straightforward interface to the Unix
select()system call. The first three arguments are iterables of „waitable objects“: either integers representing file descriptors or objects with a parameterless method namedfileno()returning such an integer:rlist: дочекатися готовності до читання
wlist: дочекатися готовності до запису
xlist: зачекайте на «виняткову умову» (перегляньте сторінку посібника щодо того, що ваша система вважає такою умовою)
Empty iterables are allowed, but acceptance of three empty iterables is platform-dependent. (It is known to work on Unix but not on Windows.) The optional timeout argument specifies a time-out as a floating-point number in seconds. When the timeout argument is omitted the function blocks until at least one file descriptor is ready. A time-out value of zero specifies a poll and never blocks.
Повернене значення — це трійка списків готових об’єктів: підмножини перших трьох аргументів. Коли час очікування досягнуто, а дескриптор файлу не готовий, повертаються три порожні списки.
Серед прийнятних типів об’єктів у ітераціях є файлові об’єкти Python (наприклад,
sys.stdinабо об’єкти, повернутіopen()абоos.popen()), сокет об’єкти, які повертаєsocket.socket(). Ви також можете визначити клас wrapper самостійно, за умови, що він має відповідний методfileno()(який дійсно повертає дескриптор файлу, а не просто випадкове ціле число).Примітка
File objects on Windows are not acceptable, but sockets are. On Windows, the underlying
select()function is provided by the WinSock library, and does not handle file descriptors that don’t originate from WinSock.Змінено в версії 3.5: Функція тепер виконується повторно з переобчисленим тайм-аутом, якщо її перериває сигнал, за винятком випадків, коли обробник сигналу викликає виняток (перегляньте PEP 475 для обґрунтування), замість того, щоб викликати
InterruptedError.
- select.PIPE_BUF¶
The minimum number of bytes which can be written without blocking to a pipe when the pipe has been reported as ready for writing by
select(),poll()or another interface in this module. This doesn’t apply to other kind of file-like objects such as sockets.POSIX гарантує, що це значення буде не менше 512.
Availability: Unix
Added in version 3.2.
/dev/poll Опитування об’єктів¶
Solaris and derivatives have /dev/poll. While select() is
O(highest file descriptor) and poll() is O(number of file
descriptors), /dev/poll is O(active file descriptors).
/dev/poll behaviour is very close to the standard poll()
object.
- devpoll.close()¶
Закрийте файловий дескриптор об’єкта опитування.
Added in version 3.4.
- devpoll.closed¶
True, якщо об’єкт опитування закрито.Added in version 3.4.
- devpoll.fileno()¶
Повертає номер дескриптора файлу об’єкта опитування.
Added in version 3.4.
- devpoll.register(fd[, eventmask])¶
Зареєструйте дескриптор файлу з об’єктом опитування. Подальші виклики методу
poll()перевірятимуть, чи є в дескрипторі файлу будь-які незавершені події введення/виведення. fd може бути або цілим числом, або об’єктом із методомfileno(), який повертає ціле число. Файлові об’єкти реалізуютьfileno(), тому їх також можна використовувати як аргумент.eventmask is an optional bitmask describing the type of events you want to check for. The constants are the same that with
poll()object. The default value is a combination of the constantsPOLLIN,POLLPRI, andPOLLOUT.Попередження
Registering a file descriptor that’s already registered is not an error, but the result is undefined. The appropriate action is to unregister or modify it first. This is an important difference compared with
poll().
- devpoll.modify(fd[, eventmask])¶
Цей метод виконує
unregister(), а потімregister(). Це (трохи) ефективніше, ніж робити те саме явно.
- devpoll.unregister(fd)¶
Видаліть дескриптор файлу, який відстежується об’єктом опитування. Як і метод
register(), fd може бути цілим числом або об’єктом із методомfileno(), який повертає ціле число.Спроба видалити дескриптор файлу, який ніколи не був зареєстрований, безпечно ігнорується.
- devpoll.poll([timeout])¶
Polls the set of registered file descriptors, and returns a possibly empty list containing
(fd, event)2-tuples for the descriptors that have events or errors to report. fd is the file descriptor, and event is a bitmask with bits set for the reported events for that descriptor —POLLINfor waiting input,POLLOUTto indicate that the descriptor can be written to, and so forth. An empty list indicates that the call timed out and no file descriptors had any events to report. If timeout is given, it specifies the length of time in milliseconds which the system will wait for events before returning. If timeout is omitted, -1, orNone, the call will block until there is an event for this poll object.Змінено в версії 3.5: Функція тепер виконується повторно з переобчисленим тайм-аутом, якщо її перериває сигнал, за винятком випадків, коли обробник сигналу викликає виняток (перегляньте PEP 475 для обґрунтування), замість того, щоб викликати
InterruptedError.
Опитування (epoll) об’єктів тригера краю та рівня¶
https://linux.die.net/man/4/epoll
маска події
Постійний
Значення
EPOLLINДоступний для читання
EPOLLOUTДоступний для запису
EPOLLPRIТермінові дані для читання
EPOLLERRСталася помилка на доц. fd
EPOLLHUPЗависання сталося на доц. fd
EPOLLETВстановіть поведінку Edge Trigger, за замовчуванням це Level Trigger
EPOLLONESHOTВстановіть одноразову поведінку. Після вилучення однієї події fd внутрішньо вимикається
EPOLLEXCLUSIVEРозбудити лише один об’єкт epoll, якщо пов’язаний fd має подію. За замовчуванням (якщо цей прапорець не встановлено) всі об’єкти epoll запитуються на fd.
EPOLLRDHUPПотоковий сокет закрив однорангове з’єднання або завершив запис половини з’єднання.
EPOLLRDNORMЕквівалент
EPOLLIN
EPOLLRDBANDСмугу пріоритетних даних можна зчитувати.
EPOLLWRNORMЕквівалент
EPOLLOUT
EPOLLWRBANDПріоритетні дані можуть бути записані.
EPOLLMSGІгнорується.
Added in version 3.6:
EPOLLEXCLUSIVEдодано. Він підтримується лише ядром Linux 4.5 або новішої версії.
- epoll.close()¶
Закрийте дескриптор керуючого файлу об’єкта epoll.
- epoll.closed¶
True, якщо об’єкт epoll закрито.
- epoll.fileno()¶
Повертає номер дескриптора файлу елемента керування fd.
- epoll.fromfd(fd)¶
Створіть об’єкт epoll із заданого файлового дескриптора.
- epoll.register(fd[, eventmask])¶
Зареєструйте дескриптор fd з об’єктом epoll.
- epoll.modify(fd, eventmask)¶
Змінити зареєстрований файловий дескриптор.
- epoll.unregister(fd)¶
Видаліть зареєстрований дескриптор файлу з об’єкта epoll.
Змінено в версії 3.9: Метод більше не ігнорує помилку
EBADF.
- epoll.poll(timeout=None, maxevents=-1)¶
Чекайте подій. тайм-аут у секундах (float)
Змінено в версії 3.5: Функція тепер виконується повторно з переобчисленим тайм-аутом, якщо її перериває сигнал, за винятком випадків, коли обробник сигналу викликає виняток (перегляньте PEP 475 для обґрунтування), замість того, щоб викликати
InterruptedError.
Об’єкти опитування¶
The poll() system call, supported on most Unix systems, provides better
scalability for network servers that service many, many clients at the same
time. poll() scales better because the system call only requires listing
the file descriptors of interest, while select() builds a bitmap, turns
on bits for the fds of interest, and then afterward the whole bitmap has to be
linearly scanned again. select() is O(highest file descriptor), while
poll() is O(number of file descriptors).
- poll.register(fd[, eventmask])¶
Зареєструйте дескриптор файлу з об’єктом опитування. Подальші виклики методу
poll()перевірятимуть, чи є в дескрипторі файлу будь-які незавершені події введення/виведення. fd може бути або цілим числом, або об’єктом із методомfileno(), який повертає ціле число. Файлові об’єкти реалізуютьfileno(), тому їх також можна використовувати як аргумент.eventmask — це необов’язкова бітова маска, що описує тип подій, які ви хочете перевірити, і може бути комбінацією констант
POLLIN,POLLPRIіPOLLOUT, описаних у таблицю нижче. Якщо не вказано, значення за умовчанням перевірятиме всі 3 типи подій.Постійний
Значення
POLLINЄ дані для читання
POLLPRIЄ термінові дані для читання
POLLOUTГотовий до виведення: запис не блокуватиметься
POLLERRЯкась помилка
POLLHUPПовісив
POLLRDHUPЗакрите однорангове з’єднання потокового сокета або завершіть запис половини з’єднання
POLNVALНедійсний запит: дескриптор не відкрито
Реєстрація дескриптора файлу, який уже зареєстровано, не є помилкою та має той самий ефект, що й одноразова реєстрація дескриптора.
- poll.modify(fd, eventmask)¶
Змінює вже зареєстрований fd. Це має той самий ефект, що й
register(fd, eventmask). Спроба змінити дескриптор файлу, який ніколи не був зареєстрований, викликає винятокOSErrorз errnoENOENT.
- poll.unregister(fd)¶
Видаліть дескриптор файлу, який відстежується об’єктом опитування. Як і метод
register(), fd може бути цілим числом або об’єктом із методомfileno(), який повертає ціле число.Спроба видалити дескриптор файлу, який ніколи не був зареєстрований, викликає виняток
KeyError.
- poll.poll([timeout])¶
Polls the set of registered file descriptors, and returns a possibly empty list containing
(fd, event)2-tuples for the descriptors that have events or errors to report. fd is the file descriptor, and event is a bitmask with bits set for the reported events for that descriptor —POLLINfor waiting input,POLLOUTto indicate that the descriptor can be written to, and so forth. An empty list indicates that the call timed out and no file descriptors had any events to report. If timeout is given, it specifies the length of time in milliseconds which the system will wait for events before returning. If timeout is omitted, negative, orNone, the call will block until there is an event for this poll object.Змінено в версії 3.5: Функція тепер виконується повторно з переобчисленим тайм-аутом, якщо її перериває сигнал, за винятком випадків, коли обробник сигналу викликає виняток (перегляньте PEP 475 для обґрунтування), замість того, щоб викликати
InterruptedError.
Об’єкти Kqueue¶
- kqueue.close()¶
Закрийте дескриптор керуючого файлу об’єкта kqueue.
- kqueue.closed¶
True, якщо об’єкт kqueue закрито.
- kqueue.fileno()¶
Повертає номер дескриптора файлу елемента керування fd.
- kqueue.fromfd(fd)¶
Створіть об’єкт kqueue із заданого файлового дескриптора.
- kqueue.control(changelist, max_events[, timeout]) eventlist¶
Низькорівневий інтерфейс для kevent
список змін має бути ітерованим об’єктами kevent або
Nonemax_events має бути 0 або додатним цілим числом
тайм-аут у секундах (можливі флоати); типовим є
None, чекати вічно
Змінено в версії 3.5: Функція тепер виконується повторно з переобчисленим тайм-аутом, якщо її перериває сигнал, за винятком випадків, коли обробник сигналу викликає виняток (перегляньте PEP 475 для обґрунтування), замість того, щоб викликати
InterruptedError.
Об’єкти Kevent¶
https://man.freebsd.org/cgi/man.cgi?query=kqueue&sektion=2
- kevent.ident¶
Значення, що використовується для ідентифікації події. Інтерпретація залежить від фільтра, але зазвичай це дескриптор файлу. У конструкторі ident може бути або int, або об’єктом із методом
fileno(). kevent зберігає ціле число всередині.
- kevent.filter¶
Назва фільтра ядра.
Постійний
Значення
KQ_FILTER_READБере дескриптор і повертає, коли є дані, доступні для читання
KQ_FILTER_WRITEБере дескриптор і повертає щоразу, коли є дані для запису
KQ_FILTER_AIOзапити AIO
KQ_FILTER_VNODEПовертається, коли відбувається одна або кілька запитаних подій, які переглядаються в fflag
KQ_FILTER_PROCСлідкуйте за подіями в ідентифікаторі процесу
KQ_FILTER_NETDEVСтежити за подіями на мережевому пристрої [недоступно в macOS]
KQ_FILTER_SIGNALПовертається щоразу, коли спостережуваний сигнал надходить до процесу
KQ_FILTER_TIMERВстановлює довільний таймер
- kevent.flags¶
Дія фільтра.
Постійний
Значення
KQ_EV_ADDДодає або змінює подію
KQ_EV_DELETEВилучає подію з черги
KQ_EV_ENABLEPermitscontrol() to повертає подію
KQ_EV_DISABLEВимкнути подію
KQ_EV_ONESHOTВидаляє подію після першого входження
KQ_EV_CLEARСкинути стан після отримання події
KQ_EV_SYSFLAGSвнутрішня подія
KQ_EV_FLAG1внутрішня подія
KQ_EV_EOFФільтр певної умови EOF
KQ_EV_ERRORПерегляньте значення, що повертаються
- kevent.fflags¶
Фільтрувати певні прапорці.
KQ_FILTER_READіKQ_FILTER_WRITEпозначки фільтрів:Постійний
Значення
KQ_NOTE_LOWATнизька позначка буфера сокета
KQ_FILTER_VNODEпозначки фільтра:Постійний
Значення
KQ_NOTE_DELETEВикликано unlink()
KQ_NOTE_WRITEвідбувся запис
KQ_NOTE_EXTENDфайл було розширено
KQ_NOTE_ATTRIBатрибут було змінено
KQ_NOTE_LINKкількість посилань змінилася
KQ_NOTE_RENAMEфайл було перейменовано
KQ_NOTE_REVOKEдоступ до файлу скасовано
KQ_FILTER_PROCпозначки фільтра:Постійний
Значення
KQ_NOTE_EXITпроцес вийшов
KQ_NOTE_FORKпроцес викликав fork()
KQ_NOTE_EXECпроцес виконав новий процес
KQ_NOTE_PCTRLMASKпрапор внутрішнього фільтра
KQ_NOTE_PDATAMASKпрапор внутрішнього фільтра
KQ_NOTE_TRACKвиконайте процес через fork()
KQ_NOTE_CHILDповернуто дочірнім процесом для NOTE_TRACK
KQ_NOTE_TRACKERRне може прив’язатися до дитини
KQ_FILTER_NETDEVпозначки фільтра (недоступні в macOS):Постійний
Значення
KQ_NOTE_LINKUPпосилання працює
KQ_NOTE_LINKDOWNпосилання не працює
KQ_NOTE_LINKINVстан посилання недійсний
- kevent.data¶
Фільтр конкретних даних.
- kevent.udata¶
Визначене користувачем значення.