Вопросы

Использованные поисковые фильтры:

10 вопросов (0.2448)

Паттерн producer/consumer достаточно часто встречается в многопоточном программировании. Его смысл состоит в том, что один или несколько потоков производят данные, и параллельно этому один или несколько потоков потребляют их. Как правильно имплементировать этот патт...
Паттерн producer/consumer достаточно часто встречается в многопоточном программировании. Его смысл состоит в том, что один или несколько потоков производят данные, и параллельно этому один или несколько потоков потребляют их. Как правильно имплементировать этот патт...
Как я могу создать очередь потоков, что бы они выполнялись в каком-то пуле по 50 штук, например ? То есть одновременно выполнялось 50 каких-то тасков и как только один из них закончился, из очереди брался следующий и так пока вся очередь не закончится.
Есть очередь задач, создана следующим образом: Значение maximumPoolSize равно 200. Во время работы в queue попадает большое количество потоков (больше тысячи), но значение, возвращаемое методом threadPoolExecutor.getActiveCount() всегда меньше либо р...
Нужно написать класс, который организует последовательную работу некоторых заданий. Задания по времени могут длится от нескольких минут до часа. Для запуска задания требуется массив с идентификаторами (integer). Так же в этом классе нужен буфер для хранения этих идентификаторов. Опишу принцип раб...
У меня есть 1 поток, который постоянно получает данные из OutputStream, а есть 2 поток, который должен получать задачи от первого и по очереди их выполнять, и подчёркиваю, это очень важно, ПО ОЧЕРЕДИ! А не получил задачи и выполняет их в разнобой. Вот тут я и не ...
Здравствуйте. Столкнулся с проблемой очерёдности заданий в Celery. Запускаю сервер RabbitMQ Запускаю Celery (app = Celery('celery_tasks', broker='amqp://guest:guest@localhost:5672//', backend='amqp')) Запускаю скрипт где вызываются функции test.delay(4, ...
Мне потребовалась очередь команд, где множество потоков может добавлять команды на выполнение и один поток по очереди их выполняет. Тк я не знаю какие-либо стандартные реализации подобного, то пришлось делать самому. Можете оценить мой класс для этого, тк у меня сомнения на счет его качества, хот...
Как мне передать свои данные в очередь Queue что бы при обработке очереди в методе handle() - производились операции над ними? Пробую кидать как в примере но данные мои только из последней очереди показывает, тоесть если элемент в очереди 1 то все хорошо, но если больше то только последний $my_da...