producer-consumer

0열

1답변

생산자/소비자는 세마포어를 사용합니다. 소비자는 대기열의 머리가 아닌 꼬리를 얻습니다.

제목에서 알 수 있듯이, 이것은 세마포어를 사용하는 생산자/소비자 구현물입니다. 교착 상태 문제는 없지만 Consumer가 대기열의 다음 항목을 제거하려고 할 때마다 항상 꼬리입니다. 의사 코드 : 0 항목 1을 제조 0 제조 상품 가치 ... ... 값 1 : class Consumer { while (!q.isEmpty() || !dataRea

java multithreading queue producer-consumer 2014-06-23

---

-1열

1답변

JMS (Java Message Service)

JMS here에 대해 읽었으며 "나는 더 간단한 소비자/제작자를 작성했습니다 ..."라고 생각했습니다. 나는 JMS의 힘에 대해 순진한가? 웹 서비스를 통해 작업하는 것이 더 간단하다고 생각하면 XML 문서를 잡고 Queue에 팝업하십시오. 제가 잘못하고있는 접근법입니까?

java jms producer-consumer 2014-06-24

---

1열

1답변

다중 생산자 단일 소비자 - 분할 오류

여러 제작자의 단일 소비자 문제를 해결하고 다음 코드는 무한 while 루프에서 하나의 제작자와 소비자 스레드를 보여줍니다 (코드를 테스트하기 위해이 작업을 수행함). Pushed : Removed : 1010 Pushed : 10 Pushed : 10 Pushed : 10 Pushed : 10 Removed : 10 Removed : 10

c++ producer-consumer 2014-05-11

---

47열

5답변

카프카 : 사육사는 필수입니까?

카프카에서는 하나의 브로커, 단일 주제 및 하나의 생산자와 다수의 소비자 (각 소비자는 브로커로부터 자체 데이터 복사본을 얻음)가있는 단일 파티션 만 사용하고자합니다. 이 점을 감안할 때, 나는 사육사 (Zookeeper) 사용의 오버 헤드를 원하지 않는다. 브로커 만 사용하면 안됩니까? 사육사는 왜해야합니까?

partitioning apache-zookeeper producer-consumer apache-kafka broker 2014-05-20

---

0열

1답변

구성 카프카는

나는 생산자와 번들 및 저장소를 얻을 수있는 소비자로부터 중고품 번들을 보내려고하지만 나는 공식 예제를 사용하여 생산자와 소비자 greoup을 만든 을 카프카 꽤 새로운 오전 번들 배열. 내가 KeyedMessage<String, Bundle> data = new KeyedMessage<String, Bundle>("bundles", "Bundle", bu

thrift producer-consumer apache-kafka 2014-07-09

---

0열

1답변

Swing 또는 Console에서 BlockingQueue에 액세스하려면 어떻게해야합니까?

GUI 가든 콘솔이든 관계없이 Consumer과 어떻게 상호 작용합니까? consume을 공개 또는 패키지 개인으로 공개해야합니까? 마치 지뢰 지대에 들어가는 것처럼 보입니다. 소비자 : package net.bounceme.dur.client; import java.io.IOException; import java.io.ObjectOutputStre

java multithreading design-patterns producer-consumer blockingqueue 2014-07-10

---

3열

2답변

생산자/소비자 : 하나의 생산자, 여러 소비자가 각각 동일한 데이터를 사용합니다.

나는 생산자/소비자 시나리오를 가지고 있는데, 생산자와 제품을 공급하는 다수의 소비자가 제품을 소비하지 않아도됩니다. 그러나 일반적으로 제공되는 제품은 한 명의 소비자 만 사용하고 다른 소비자는이 특정 제품을 사용하지 않습니다. 내가 달성 할 수없는 것은 제품이 어떤 종류의 차단도없이 각 소비자에 의해 한 번 소비된다는 것입니다. 첫 번째 아이디어는 각 소

java multithreading producer-consumer 2014-05-24

---

-2열

2답변

멀티 스레딩을 사용하는 Producer/2consumers 구현

"producer/two consumers"기능을 구현하고 싶습니다. 프로듀서 : 스캔 디렉토리를 재귀 적으로 일부 저장 (나는 Queue<> 추측) 소비자 1 디렉토리 정보를 추가합니다 디렉토리에 대한 데이터를 검색하고 XML 파일에 기록합니다. 소비자 2 :은 디렉토리에 대한 데이터를 검색하고이를 TreeNode에 추가합니다. 이렇게 (1과 2) 소비자

c# .net multithreading producer-consumer 2014-07-19

---

0열

1답변

공유 버퍼를 지속적으로로드 및 언로드하기 위해 제작자 스레드와 소비자 스레드를 얻는 방법은 무엇입니까?

저는 공유 버퍼를 계속 채우고 비우는 두 개의 스레드 인 생산자와 소비자를 갖고 싶습니다. 코드는 약간의 의미가 있지만 나중에 실제 중지 조건을 포함하도록 확장 할 것입니다. 여기에 제 상황이 있습니다 : 저는 프로듀서 쓰레드를 시작했고, 버퍼를 채우고, 컨트롤을 소비자에게 넘겨주고, 소비자는 버퍼를 비 웁니다. 그러나 소비자는 버퍼를 다시 채우기 위해 생

c multithreading producer-consumer 2014-04-14

---

1열

2답변

프로듀서 소비자 - 자식 프로세스에서의 세마포어 사용하기

3 개의 세마포어, 2 개의 카운팅 (카운트 MAX 5) 및 임계 섹션에 대한 1 개의 바이너리 세마포어를 사용하여 Bounded 버퍼 (버퍼 크기 5) 문제를 구현했습니다. 생산자와 소비자 프로세스가 분리되어 버퍼를 공유하고있었습니다. 그런 다음 공유 메모리 (버퍼)를 설정하는 하나의 상위 프로세스와 프로듀서 및 소비자와 같은 두 개의 하위 프로세스로 동

linux operating-system semaphore producer-consumer 2014-04-19

---