Описание тега nonblocking

Вопросы с тегом
Ввод-вывод в неблокирующем режиме либо передает как минимум один байт, либо немедленно возвращается с ошибкой или концом потока. Неблокирующие алгоритмы относятся к использованию параллелизма без обычных примитивов взаимного исключения, гарантируя, что операции потока не будут блокироваться бесконечно. Обычно это выполняется с помощью операций модификации атомарного значения (увеличения / уменьшения) и / или чтения (сравнения и обмена). Не ясно, для чего предназначен этот тег.
2 ответа

Время ожидания / неблокирования adb для устройств?

Есть ли способ получить тайм-аут при вызове "adb wait-for-devices"? Сценарий: adb reboot adb wait-for-devices (timeout listed here - if possible) **if times out: echo timed out** **else** adb root adb wait-for-devices
18 ноя '14 в 02:34
2 ответа

Бегущее будущее n раз

Я хотел бы выполнить мой будущий вызов n раз, например 5. Будущее "выполнение" займет некоторое время, и я хочу вызывать новый только тогда, когда предыдущий был завершен. Что-то вроде: def fun(times: Int): Future[AnyRef] = { def _fun(times: Int) = …
08 окт '13 в 13:22
1 ответ

Дамп ядра с помощью FD_SET() и очередей сообщений на cygwin

У меня есть следующий C-код для настройки select () для прослушивания входящих данных как в сокете TCP, так и в очереди сообщений: fd_set readSet; u32 maxFD = 0; mqd_t parentQueue; int serverSocket; /* not shown: parentQueue and serverSocket were su…
01 окт '14 в 09:42
2 ответа

Бесконечный "фоновый" цикл для обработчика Tornado WebSockets

Я пытаюсь создать сервер WebSocket, используя Tornado. То, что я хотел бы сделать, это выполнить определенную команду, которая будет отправлять сообщение для каждого цикла IOLoop. Чтобы было понятнее; скажем, у меня есть следующий обработчик WebSock…
12 фев '14 в 15:10
1 ответ

Как сделать неблокирующим raw_input при использовании eventlet.monkey_patch() и почему он блокирует все, даже когда выполняется в другом потоке?

Я написал этот минимальный код, чтобы объяснить мой случай: import threading import time import eventlet eventlet.monkey_patch() def printing_function(): while True: # here i want to do some work print "printing" time.sleep(1) if __name__ == '__main…
27 янв '12 в 00:01
0 ответов

Неблокирующий ввод в Python 3

Я хотел бы кросс-платформенный способ читать входные данные из стандартного ввода неблокирующим способом. Примерно так (как это делают неблокирующие сокеты): while True try: string = input("> ") except BlockingIOError: pass else: print(f"you type…
18 апр '17 в 02:55
2 ответа

C - DNS прокси обслуживает каждый запрос в любое время

Я создал DNS-прокси в C так: "socket" - create socket to serve client "bind" - bind that socket while (true) { "recvfrom" - a package from socket "socket" - create socket for dns server (1) "sendto" - send package to dns server "recvfrom" - respond …
18 ноя '12 в 15:35
2 ответа

Должен ли я использовать для цикла асинхронный способ, когда я использую node.js?

Я тестирую с помощью node.js с помощью Express. Теоретически, если я запускаю что-то очень тяжелое вычисление для цикла for без каких-либо обратных вызовов, это заблокировано, и другой запрос должен быть проигнорирован. Но в моем случае обычная "пет…
11 янв '12 в 07:01
0 ответов

Как реализовать или использовать WebSocket в Perl?

Мне нужно иметь 3 основных вещи из Perl и не знаю, как это сделать. Неблокирующая реализация веб-сокета, такая как mojo, Сервер должен принимать широковещательные вызовы после его запуска Сервер должен иметь возможность доступа к данным, находящимся…
05 июн '14 в 18:04
2 ответа

Ruby неблокирующие библиотеки против Node

Я оцениваю Ruby EventMachine (и подобные неблокирующие фреймворки, такие как Cramp) против Node.js. Я работал с Node раньше, но никогда не работал с EventMachine. Одна из идей, которую поддерживает Райан Даль, заключается в том, что экосистема библи…
19 мар '12 в 18:52
2 ответа

Java / Groovy Socket - Обнаружение закрытия сокета неблокирующим способом

Я пытаюсь создать небольшой HTTP-прокси, который может переписать запрос / заголовки в соответствии с моими требованиями. Если он уже существует, пожалуйста, укажите мне на это. Иначе... Я написал кое-что, что ПОЧТИ работает. Он может выполнять функ…
10 июн '10 в 00:01
0 ответов

Залп, authToken и AsyncTask

Я хочу вызвать мой REST-API с помощью authToken, который я получаю , вызывая метод getAuthToken AccountManager с обратным вызовом. После этого я использую Volley для связи с моим сервером и снова получаю Error and SuccessListener. Это делает мой код…
27 апр '14 в 18:32
2 ответа

JTextArea замораживает интерфейс на больших пастах

У меня есть программа, которая позволяет пользователю вводить данные в JTextArea. Затем данные анализируются и обрабатываются для дальнейшего использования. Хотя я хорошо знаю о возможности использования неблокирующих отбрасываний файлов, и я уже пр…
17 сен '13 в 08:14
1 ответ

C - SIGALRM не получен

Я новичок в сигналах, я пытаюсь настроить SIGALRM на службу UDP echo, как практику программирования сокетов.Так что здесь у меня есть сокет UDP, клиент отправляет строку на сервер и ждет ответа (любой ответ, здесь строка повторяется сервером).Цель с…
26 июл '17 в 03:00
1 ответ

Как сделать неблокирующее соединение OpenSSL?

Я хочу сделать неблокирующее соединение OpenSSL При этом соединении - если данные недоступны для чтения, весь процесс выполнения программы останавливается на SSL_read(). Я хочу, чтобы, если нет данных, доступных для чтения, он дал мне возвращаемые з…
23 июн '15 в 14:03
0 ответов

Как я могу написать spliceAll в Linux?

Я хочу слить канал, передав все его данные в сокет, используя splice Системный вызов в Linux. Моя текущая попытка: ssize_t splice(int i, loff_t* io, int o, loff_t* oo, size_t l, unsigned int flags); int spliceAll(int i, loff_t* io, int o, loff_t* oo…
11 фев '13 в 22:52
1 ответ

Ненужное использование обратного вызова в node.js?

Я изучаю node.js, и я получил большинство основ об асинхронном неблокирующем вводе / выводе. Мой вопрос заключается в том, какой смысл создавать функцию с обратными вызовами, когда сама функция не асинхронна. Даже если созданная вами функция имеет в…
17 окт '15 в 02:29
1 ответ

Вопросы о Сервлете 3.1 Образец неблокирующего ввода-вывода

Ниже приведен код сервлета 3.1 Non Blocking IO demo: UploadServlet: @WebServlet(name = "UploadServlet", urlPatterns = {"/UploadServlet"}, asyncSupported=true) public class UploadServlet extends HttpServlet { protected void doPost(HttpServletRequest …
05 дек '15 в 12:22
1 ответ

Неблокирующий Thrift-сервер в Python

В приведенном ниже фрагменте кода я пытаюсь сделать неблокирующий Thrift-сервер на Python. # set handler to our implementation handler = ServiceHandler() processor = MyService.Processor(handler) transport = TSocket.TServerSocket(port=port) tfactory …
05 дек '11 в 11:04
0 ответов

Сортировка выполнения кода с помощью Q-обещаний

Я пытался отсортировать node.js код с Q-promise: var request = require('request'); var cheerio = require('cheerio'); var Q = require('q'); var companiesUrls = []; var url = ''; var companiesUrls2 = []; var carsUrls = []; var carsOwnerReview = {}; va…
27 авг '14 в 10:43