producer-consumer

0열

1답변

maxread 값이 크고 메시지 reaceived가 적은 양의 kafka 소비자가 무한히가는 이유는 무엇입니까?

나는 kafka Simple Consumer를 사용했다. 내가 원하는 것은 생산자로부터 메시지를받을 것이고,이 데이터는 STORM에서 처리되고 그 후에는 Cassandra에 저장 될 것입니다. 모든 것이 잘되지만 문제는 kReadka 값이 커질수록 maxReads 값이 증가 할 때입니다. 무한 루프 및 데이터 처리 및 저장 캐산드라에 결코 일어나지 않을거야

java apache-kafka producer-consumer apache-storm 2015-01-08

---

0열

1답변

어떻게하면 자바의 세마포어에서 특정 테드를 멈출 수 있습니까?

나는 생산자와 소비자 문제를 세마포어로 구현했다. 소비를위한 제품이 없을 때 현재 스레드는 생산자가 제품을 생산할 때까지 까지 기다려야합니다. 나를 안내하십시오.

java semaphore producer-consumer 2015-01-09

---

3열

1답변

로컬 Kafka 응용 프로그램과 함께 실패 : NoSuchMethodError : createEphemeral

spark 응용 프로그램을 로컬 모드로 실행하려고합니다. 모든 것을 설정하기 위해이 튜토리얼을 따라 갔다 : 로컬 kafka/zookeeper 환경을 구축하기위한 각 단계를 보여주는 http://blog.d2-si.fr/2015/11/05/apache-kafka-3/, ( 프랑스어). 소비자를 위해, val sparkConf = new SparkConf()

apache-spark apache-kafka producer-consumer apache-zookeeper 2016-05-31

---

0열

1답변

Ruby - 반복 할 때 멀티 스레딩 (생성자/소비자 모델)을 사용하면 예기치 않은 결과가 발생합니다.

참고 : DNS 이름을 확인하기 위해 스레딩을 사용하고 있지만 비슷한 동작으로 같은 동작을 재현 할 수 있습니다. (이전에 작동하는) 코드를 표준 단일 스레드 실행에서 다중 스레드로 이동하려고하면 예기치 않은 결과가 나타납니다. 특히, 내 코드는 해시 배열을 반복하고 배열의 각 해시에 키/값 쌍을 추가합니다. 새로운 키/값 쌍이 생성되는 루프의 dns_cn

ruby producer-consumer 2016-06-04

---

1열

1답변

생산자/소비자, 모든 소비자를 끄기 전에 스레드 안전 큐가 비워 졌는지 확인하는 방법?

스레드 안전 큐를 사용하는 프로젝트에서 작업하고 있습니다. 그것은 기본적으로 생산자/소비자 문제입니다. 내 코드는 현재 수행 는 큐가 비어 있지 않은 경우에도 문제가 void threadCode()//the consumer { while(active) // active is an atomic int, we use it to turn off eve

c++ multithreading thread-safety pthreads producer-consumer 2016-06-05

---

1열

1답변

프로듀서/나는 두 가지 방법이 일괄 메일 서비스 쓰기를 시도하고

배치 및 세척 기능을 가진 소비자 : add(Mail mail) : 우편물을 보낼 수는 생산자 flushMailService()에 의해 호출됩니다 서비스를 세척하십시오. 소비자는 목록을 가져 와서 다른 (값 비싼) 방법을 호출해야합니다. 일반적으로 비싼 방법은 배치 크기에 도달 한 후에 만 ​​호출해야합니다. 이이 질문에 다소 유사합니다 Producer/C

java multithreading concurrency queue producer-consumer 2016-06-09

---

1열

2답변

은 - 왜) (이 통지하지

내가 public class BlockingQueue { private List queue = new LinkedList(); private int limit = 10; public BlockingQueue(int limit){ this.limit = limit; } public synchroni

java multithreading client-server producer-consumer 2015-02-01

---

0열

1답변

생산자의 종료 Consumer multithreading Java

멀티 스레드 및 Java 동시성 기능에 대한 연습을하고 있습니다. 1 명의 생산자와 4 명의 소비자가 있습니다. 이제 내 질문은 : 생산자가 BlockingQueue에서 생산을 완료했다고 확신 할 때 소비자를 중단시키는 더 현명한 방법이 있습니까? 지금은 대기열에 -1 정수를 사용하고 있지만 매우 기초적으로 보입니다! 는 public class Exerci

java multithreading producer-consumer blockingqueue executors 2015-02-04

---

3열

1답변

스레드 출구에서 대기자에게 알리기

다음 예제를 고려하십시오. 한 명의 생산자와 N 명의 소비자가 데이터를 기다리고 있다고 가정합니다. 데이터가 준비 될 때마다뿐만 아니라 제작자가 어떤 이유 (오류 또는 중단 지점)로 종료 할 때도 고객에게 알리고 싶습니다. 후자의 경우 독자는 물론 종료해야합니다. // Globals boost::shared_future<void> future; boos

c++ c++11 boost boost-thread producer-consumer 2015-02-07

---

0열

1답변

생산자 - 소비자가 breakpoint에서만 작동하는 arraydeque 사용

ArrayDeque를 사용하고 이상한 문제로 실행되는 생산자 및 소비자 패턴을 구현 중입니다. Consumer.java Class Consumer { public final Queue<Msg> my_queue = new ArrayDeque<Msg>(); public void begin() { new Thread() {

java producer-consumer arraydeque 2014-12-31

---