blockingqueue

0зной

2ответ

Производитель Потребитель с помощью блокировки очереди

У меня есть реализация Producer/Consumer с помощью блокировки, я начинаю их как этот BlockingQueue<Object> myQueue1 = new LinkedBlockingQueue<Object>(); new Thread(new SmsInProducer(myQueue1, 100)).s

java producer-consumer blockingqueue 2012-03-02

---

3зной

2ответ

потребитель-производитель - ExecutorService & ArrayBlockingQueue

Я хочу знать, правильно ли я понимаю, что потребительский дизайн производителя является правильным, используя ExecutorService & ArrayBlockingQueue. Я понимаю, что существуют различные способы реализац

java multithreading concurrency producer-consumer blockingqueue 2012-05-01

---

0зной

2ответ

в то время как цикл в реализации Java BlockingQueue

Недавно я увидел следующую реализацию Епдиеие для BlockingQueue (source) public synchronized void enqueue(Object item) throws InterruptedException { while(this.queue.size() == this.limit) {

java blockingqueue 2012-03-23

---

4зной

3ответ

Реализация очереди блокировки в Haskell

В java есть хороший пакет java.util.concurrent, который содержит реализацию для интерфейса BlockingQueue. мне нужно что-то подобное в Haskell, так что он будет иметь возможность поддерживать фиксирова

haskell blockingqueue 2012-02-12

---

1зной

1ответ

Производитель Потребитель в Java

Я написал следующий код, но я чувствую, что происходит не так-то: public class ProcessQueue { static BlockingQueue<String> queue = new LinkedBlockingQueue<String>(); public ProcessQueue() { p

java producer-consumer blockingqueue 2012-04-13

---

1зной

3ответ

BlockingQueue - выбор только определенного объекта.

У меня есть следующий blockingQueue; final BlockingQueue<Message> blockingQueue = new LinkedBlockingQueue<Message>(); где public class Message { private String author; private String text;

java concurrency blockingqueue 2012-03-19

---

1зной

1ответ

Канал для обмена данными между потоками

У меня есть требование, когда мне нужно прочитать текстовый файл, а затем преобразовать его и записать в какой-либо другой файл. Я хочу сделать это параллельно, как один поток для чтения, один для пре

java guava blockingqueue 2012-02-08

---