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

Поведение тайм-аута неблокирующего сокета Java Linux
У меня есть неблокирующий сервер Java, который отслеживает все каналы сокетов в селекторе. Затем я устанавливаю 500 подключений к серверу и регулярно отправляю данные. Каждая часть данных, которую получает сервер, возвращается клиенту. Проблема...
2829 просмотров
schedule 29.05.2024

Атомная инструкция
Что вы имеете в виду под атомными инструкциями? Как следующее становится атомарным? TestAndSet int TestAndSet(int *x){ register int temp = *x; *x = 1; return temp; } С точки зрения программного обеспечения, если кто-то не хочет...
19885 просмотров

TNonblockingServer, TThreadedServer и TThreadPoolServer, какой из них лучше всего подходит для моего случая?
Наш аналитический сервер написан на C++. Он в основном запрашивает базовый механизм хранения и возвращает довольно большие структурированные данные по бережливости. Обработка типичного запроса занимает от 0,05 до 0,6 секунды в зависимости от размера...
12077 просмотров

Jetty или Tomcat с неблокирующим вводом-выводом (сервлет 3.0)
Мне нужна точка, с которой нужно начать. Я читал у Якова Файна о прорыве спектакля с пристанью и пламенем. Я понял, что у нас уже есть некоторые проблемы с примерно 1200 одновременных пользователей, некоторые потребители не получают сообщения, а...
2328 просмотров

Как сделать отложенный неблокирующий вызов функции
Я хочу вызвать функцию add HashSet с некоторой задержкой, но без блокировки текущего потока. Есть ли простое решение для достижения чего-то вроде этого: Utils.sleep(1000, myHashSet.add(foo)); //added after 1 second //code here runs immediately...
16909 просмотров

установка времени ожидания подключения для Net::LDAP
У меня есть код perl, работающий под mod_perl, который подключается к серверу openldap slapd с помощью модуля Net::LDAP. Я пытаюсь установить тайм-аут подключения следующим образом: my $ldap = Net::LDAP->new($server, timeout => 120);...
2493 просмотров
schedule 13.06.2024

Как мне сделать неблокирующее поведение сервера в C, когда я хочу получить только одно соединение?
В C предположим, что у меня есть серверное приложение. Сокет настроен правильно и привязан к локальному порту, а функция listen() вызывается без ошибок. Код такой: //obtain a connection. int connection; struct sockaddr_storage...
255 просмотров
schedule 19.01.2024

Неблокирующий FIFO: определить, существует ли читатель?
Я создал FIFO, в который я могу выполнять неблокирующие записи следующим образом: // others, searching for a non-blocking FIFO-writer may copy this ;-) mkfifo("/tmp/myfifo", S_IRWXU); int fifo_fd = open("/tmp/myfifo", O_RDWR); fcntl(fifo_fd,...
3684 просмотров
schedule 23.02.2024

gevent TCP-сервер в Windows
Я пытался создать TCP-сервер с gevent без (какого-либо серьезного) успеха до сих пор. Я думаю, что проблема кроется в Windows (раньше у меня были проблемы с сокетами под Windows). Я использую Python2.7, gevent0.13 под Windows7. Вот мой код:...
819 просмотров
schedule 08.10.2022

Python-эквивалент Java tryLock (идиоматический)?
В Java tryLock (long time, TimeUnit unit) может использоваться как неблокирующая попытка получить блокировку. Как можно достичь эквивалента в Python? (Предпочтителен Pythonic | идиоматический способ!) Java tryLock: ReentrantLock lock1 =...
2918 просмотров

Когда неблокирующая send () передает только частичные данные, можем ли мы предположить, что при следующем вызове она вернет EWOULDBLOCK?
На страницах руководства хорошо описаны два случая для неблокирующих сокетов: Если send () возвращает ту же длину, что и буфер передачи, вся передача завершена успешно, и сокет может или не может быть в состоянии возврата EAGAIN / EWOULDBLOCK...
20541 просмотров
schedule 23.10.2023

Python + Tornado для бухгалтерского ПО
Мы собираемся создать «Бухгалтерское программное обеспечение (назовем его AS)» для средних и крупных компаний. Таким образом, AS будет всеобъемлющим и будет иметь множество связанных модулей. AS будет работать в облаке и имеет подход SOA. Я хотел...
1134 просмотров

Кэширование сетевого потока в golang?
Я пытаюсь написать кеширующий прокси для видеопотоков в golang. Мой вопрос: как распределить потоковую копию больших кусков данных между несколькими соединениями? Или как хранить (кешировать) и безопасно (и быстро) получать доступ к данным из...
871 просмотров

SSL_shutdown возвращает -1 с бесконечно длинным SSL_ERROR_WANT_READ
Я не могу понять, как правильно использовать команду SSL_Shutdown в OpenSSL. Подобные вопросы возникали несколько раз в разных местах, но я не смог найти решение, которое точно соответствовало бы моей ситуации. Я использую пакет libssl-dev...
893 просмотров
schedule 27.01.2024

Как получить поток ввода во время выполнения другого цикла while в С++
Я пишу игру на С++, которая использует pdcurses для получения ввода от пользователя и отображения постоянно меняющегося статуса игрока. на терминале командной строки. Я использую цикл while для непрерывного обновления состояния здоровья игрока...
114 просмотров

Неожиданный результат от MPI isend и irecv
Моя цель состояла в том, чтобы отправить вектор из процесса 0 в процесс 1. Затем отправить его обратно из процесса 1 в процесс 0. У меня есть два вопроса из моей реализации, 1- Почему отправка обратно из процесса 1 в процесс 0 занимает больше...
494 просмотров

C++ неблокирующее чтение
Все, что мне нужно сделать, это просто прочитать все доступные байты из сокета. Но есть одно условие: есть метод, который читает n байт из неблокирующего сокета, который я должен использовать для реализации другого метода, который будет читать все...
1791 просмотров
schedule 10.02.2024

python: как сделать периодический неблокирующий поиск
Не могли бы вы посоветовать, как периодически выполнять задачу, выполнение которой занимает больше времени, чем периодический интервал? Например: def lookup(): # do some lookups, retrieve info, let's assume it takes 60sec to complete...
682 просмотров

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

Как я могу вычислить сообщение, которое будет отправлено на канал как можно позже?
Мой сценарий: У меня есть производитель и потребитель. Обе являются горутинами и общаются через один канал. Производитель способен (теоретически) генерировать сообщение в любое время. Генерация сообщения требует некоторых вычислений....
44 просмотров
schedule 01.04.2024