blockingqueue

В частности, я ищу блокирующую очередь. Есть ли такая вещь в C++11? Если нет, то каковы мои другие варианты? Я действительно больше не хочу спускаться на уровень нитей. Слишком подвержен ошибкам....

У меня есть следующий довольно простой интерфейс обратного вызова и класс POJO: public interface Action{ public void doAction(); } public class Person{ private String name; private String address; //...etc //GET, SET, toString } И я собираюсь использовать его следующим образом: ...

У меня есть блокирующая очередь, в которой пишут несколько авторов. Я хочу поставить механизм управления транзакциями, где не более, скажем, 50 писателей(или около того) могут писать в секунду. Есть ли способ достичь этого? Edit 1: аналогичное требование предъявляется и к методу записи SocketChannel. То есть...

Я просматривал исходный код ArrayBlockingQueue и LinkedBlockingQueue. LinkedBlockingQueue имеет putLock и takeLock для вставки и удаления соответственно, но ArrayBlockingQueue использует только 1 блокировку. Я считаю, что LinkedBlockingQueue был реализован на основе дизайна, описанного в простой, быстрый и п...

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

у меня есть один потоковый производитель, который создает некоторые объекты задачи, которые затем добавляются в ArrayBlockingQueue (который имеет фиксированный размер). Я также запускаю многопоточный потребитель. Это сборка в виде фиксированного пула потоков (Executors.newFixedThreadPool(threadCount);). Зате...