Вопросы по теме 'nonblocking'

Неблокирующий алгоритм для генерации уникальных отрицательных чисел
Недавно я провел рефакторинг фрагмента кода, используемого для генерации уникальных отрицательных чисел. редактирование: несколько потоков получают эти идентификаторы и добавляют их в качестве ключей в БД; числа должны быть отрицательными, чтобы их...
1340 просмотров
schedule 25.06.2022

Как оставить отзыв при загрузке миниатюр и контролировать порядок загрузки
Я создаю веб-сайт, содержащий около 250–300 эскизов на одной странице, содержащихся в 5 разных блоках, каждый из которых можно прокручивать по горизонтали. Однако на этапе загрузки мне нужно иметь возможность щелкнуть эскиз и загрузить изображение в...
300 просмотров
schedule 29.09.2022

Неблокирующий стдио
Я работаю над программой, которая будет принимать пользовательский ввод с консоли, а также распечатывать в отдельном потоке. Я хочу избежать ситуаций, когда пользователь набирает что-то на полпути, а появляется printf и печатает себя на курсоре....
3788 просмотров
schedule 01.08.2023

Сериализация Java, ObjectInputStream.readObject(), проверьте, будет ли блокироваться
Я использую ObjectInputStream для вызова readObject для чтения в сериализованном Objects . Я хотел бы избежать блока этого метода, поэтому я хочу использовать что-то вроде Inputstream.available() . InputStream.available() сообщит вам, что...
17830 просмотров
schedule 03.02.2023

Python: неблокирующее чтение из стандартного вывода многопоточного подпроцесса
У меня есть скрипт (worker.py), который выводит небуферизованный вывод в виде... 1 2 3 . . . n где n — некоторое постоянное количество итераций, которое будет выполнять цикл в этом скрипте. В другом скрипте (service_controller.py) я запускаю...
2780 просмотров

recv с MSG_NONBLOCK и MSG_WAITALL
Я хочу использовать системный вызов recv с неблокирующими флагами MSG_NONBLOCK. Но с этим флагом системный вызов может вернуться до того, как будет выполнен полный запрос. Так, я могу добавить флаг MSG_WAITALL? Будет ли он неблокирующим?...
20978 просмотров

Ruby 1.8 и дисковый ввод-вывод в многопоточной настройке
Ruby 1.8 использует потоки пользовательского пространства, а не потоки операционной системы. Это означает, что Ruby 1.8 может использовать только одно ядро ​​​​ЦП, независимо от того, сколько потоков Ruby вы создаете. С другой стороны, не все так...
569 просмотров
schedule 03.04.2023

C fork/exec с неблокирующим каналом ввода-вывода
Кажется, это довольно распространенная вещь, и мне удалось научиться всему, что мне нужно, чтобы заставить ее работать, за исключением того, что теперь у меня есть единственная проблема, которая не поддается моему устранению неполадок. int...
7477 просмотров
schedule 13.04.2022

IO # читать блоки на неблокирующем сокете?
Руби 1.8.7. Я вызываю чтение для сокета, который был открыт и связан с: socket = Socket.new(AF_INET, SOCK_STREAM, 0) sockaddr = Socket.sockaddr_in(mp.port, mp.ip_address.ip) begin socket.connect_nonblock(sockaddr) [...] Соединение...
2564 просмотров
schedule 30.08.2022

Python/Erlang: в чем разница между Twisted, Stackless, Greenlet, Eventlet, Coroutines? Они похожи на процессы Erlang?
Мое неполное понимание заключается в том, что Twisted, Stackless, Greenlet, Eventlet, Coroutines используют асинхронный сетевой ввод-вывод и пользовательские потоки, которые очень легкие и быстро переключаются. Но я не уверен, каковы различия между...
7201 просмотров

Как узнать, блокирует ли сокет режим или нет? В Windows
Возможный дубликат: Есть ли в Win32 способ проверить, является ли сокет неблокирующим? В Unix я могу использовать fcntl(). Есть ли какой-нибудь Winsock API, который я могу использовать для проверки режима блокировки сокета или нет?
303 просмотров
schedule 06.06.2023

Как создать Java неблокирующий InputStream из HttpsURLConnection?
По сути, у меня есть URL-адрес, который передает XML-обновления из чата при публикации новых сообщений. Я хотел бы превратить этот URL-адрес в InputStream и продолжать чтение из него, пока поддерживается соединение и пока я не отправил...
33260 просмотров
schedule 09.09.2023

MPI_Bsend и MPI_Isend. Как они работают?
используя буферизованную отправку и неблокирующую отправку, мне было интересно, как они реализуют новый уровень параллелизма в моем приложении, в конечном итоге генерируя поток. Представьте, что ведомый процесс генерирует большое количество данных и...
1492 просмотров

Смущает неблокирующий ввод-вывод OpenSSL
В общем, библиотека OpenSSL (C API), кажется, предлагает два способа сделать все: вы можете либо использовать простые системные сокеты, настроенные по своему вкусу, либо вы можете использовать объекты OpenSSL BIO , которые похожи на потоки. Однако...
7114 просмотров
schedule 03.09.2022

Чтение из дескриптора открытого файла, который записывается в Python
Я знаю, что это классическая проблема в потоковой обработке, но я не знаю, как с ней справиться в Python. У меня есть дескриптор файла, который записывается активным процессом. Я хочу потреблять содержимое из этого файлового дескриптора построчно,...
2613 просмотров
schedule 24.01.2023

Предположение о машинной инструкции в смысле многопоточности
Можно ли предположить, что в каждой инструкции соблюдается атомарность? Например, mov dword ptr [eax], 0 Движение либо идет успешно, либо не происходит. в середине выполняемой инструкции нет прерывания. Верно ли мое предположение? Я...
216 просмотров

Код Python зависает при попытке открыть именованный канал для чтения
Я пытаюсь настроить двустороннюю связь между демоном и клиентом, используя именованные каналы. Код зависает при попытке открыть именованный канал, используемый для ввода. Почему? class comm(threading.Thread): def __init__(self): self.srvoutf...
7942 просмотров
schedule 28.04.2022

Блокирует ли аффилированный SocketChannel неблокирующий SocketChannel?
Я разрабатываю приложение для Android, пытаясь выполнить неблокирующую запись из одного потока в сокете, выполняя блокировку чтения в другом потоке. Я просматриваю документы SocketChannel и пытаюсь выяснить, что именно делает configureBlocking. В...
1157 просмотров

Использование libcurl с libevent
Может ли кто-нибудь показать (через код) или объяснить мне, как я могу использовать libevent и curl вместе в программе c? Я пытаюсь написать высокопроизводительный неблокирующий монитор данных, которому необходимо загружать данные в экземпляр...
4161 просмотров
schedule 27.03.2023

сокет не блокируется при операции записи: OpenSolaris
У меня есть модульный тест, который проверяет поведение на блокирующих и неблокирующих сокетах — сервер пишет длинный ответ, и в какой-то момент он больше не может писать и блокируется при записи. Обычно одна сторона пишет, а другая не читает....
606 просмотров