producer-consumer

0열

1답변

kafka-avro-console-producer를 사용하는 방법?

'kafka-console-producer'를 사용하면 JASS 파일이 자동으로 선택되어 정상적으로 실행됩니다 (원격 주제로 생성 될 수 있음). 내가 사용하는 경우 '카프카 - 브로 콘솔 프로듀서'동일한 구성으로하지만, 추가 스키마 속성 -이 JASS 구성에 대해 불평 : 'Could not find a 'KafkaClient' entry in the J

properties apache-kafka producer-consumer producer 2017-10-12

---

1열

2답변

Java 다중 스레드 프로그램에서 생산자 소비자 스레드의 상호 교환 가능한 역할

목표 : 생산자 스레드와 소비자 스레드가 상호 작동 할 수 있도록 두 개의 스레드를 만들려면 첫 번째 스레드가 두 번째 스레드보다 생산자 역할을하며 그 반대의 경우도 마찬가지입니다. 세부 사항 : 그들은 버퍼를 통해 서로 통신하며 하나의 정수 크기를 저장합니다. 예를 들어 첫 번째 스레드가 1을 생성하면 두 번째 스레드는이를 소비하고 2를 생성 한 다음 첫

java multithreading producer-consumer 2017-12-25

---

0열

1답변

Kafka 및 Spark Streaming Simple Producer Consumer

제작자가 보낸 데이터가 소비자에게 전달되지 않는 이유를 알 수 없습니다. cloudera 가상 시스템을 연구 중입니다. 저는 생산자가 Kafka를 사용하고 소비자가 스파크 스트리밍을 사용하는 간단한 제작자 소비자를 작성하려고합니다. 스칼라의 생산자 코드 : 스칼라에서 import java.util.Properties import org.apache.kaf

scala apache-kafka spark-streaming producer-consumer 2017-11-19

---

0열

1답변

OpenMP를 사용하여 C++로 모니터를 구현하는 방법은 무엇입니까?

저는 C++에서 Producer-consumer problem을 연구하고 있는데 OpenMP를 사용할 때 모니터를 구현하는 방법은 무엇입니까? OpenMP에서 conditional_variable과 같은 항목을 찾을 수 없어 위키 피 디아 예제와 같은 특정 조건에 대해 대기/알림을 구현할 수 없습니다.

c++ multithreading openmp producer-consumer 2017-10-20

---

0열

1답변

파이썬에서 실행중인 스레드에서 메소드를 변경하거나 메소드를 호출하는 방법은 무엇입니까?

직렬 연결에서 데이터를 생성하고 다른 소비자 스레드가 사용할 여러 대기열에 넣는 제작자 스레드가 있습니다. 그러나, 생산자 스레드가 이미 실행을 시작한 후에 주 스레드에서 추가 대기열 (추가 소비자)을 추가 할 수 있기를 원합니다. e.e. 아래의 코드에서이 스레드가 실행되는 동안 주 스레드에서 listOfQueues에 대기열을 추가하는 방법은 무엇입니까?

python multithreading python-multithreading producer-consumer 2017-10-22

---

0열

1답변

여러 운영자가 3 가지 도구를 공유하고 교착 상태를 피하는 방법?

나는이 특정 교착 상태를 해결하기 위해 몇 가지 제안을 부탁드립니다 : 3 operators, each is given 2 of 3 different materials at random: 1, 2, 3 3 tools, each material needs a different tool to process by an operator. material

deadlock producer-consumer 2017-10-26

---

-1열

1답변

단순한 생산자 및 소비자의 unique_lock에 대한 어려움

C++ 11 개의 노트를 기반으로 작성된 매우 간단한 프로듀서/소비자를 작성했으며 unique_lock()이 범위를 벗어날 때 잠금을 해제하지 않는 이유를 파악할 수 없습니다. 출력은 thread Q(&consumer); thread P(&producer); P.join(); Q.join(); : - : -로 struct Me

c++ c++11 producer-consumer unique-lock 2017-12-20

---

0열

1답변

하나의 생산자 Executors.newSingleThreadExecutor()로 10 명의 소비자가 파일 처리

임의로 선택한 용량이 10 인 LinkedBlockingQueue와 1000 행의 입력 파일이 있습니다. 내- Executors.newSingleThreadExecutor() - line == null까지 호출 buffer.readline()를 사용하여 처음으로 처리하는 서비스 클래스의 main 메서드에서 하나의 ExecutorService -type 변수

java multithreading batch-processing executorservice producer-consumer 2017-09-26

---

-1열

1답변

BlockingCollection을 사용하여 생산자/소비자 패턴 비동기에 항목 추가하기

생산자/소비자 패턴을 구현하기 위해 this guide을 BlockingCollection에 올리 겠지만 여전히 생산자 측에서 병렬로 작업을 수행 할 수 없습니다. 문제는 내 foreach 블록이 순차적으로 실행되고 있습니다. this question에서 프로젝트 컬렉션이 PropertyLien<T>Task s 인 것으로 알고 있습니다. 어떻게 된거 야?

c# asynchronous task producer-consumer 2017-11-15

---

1열

1답변

C 파이프 : 잘못된 파일 설명자

C에서 간단한 프로듀서 소비자 프로그램이 있습니다. 포크로 해결하려고 시도합니다. 생산자가 파이프에 쓰려고 할 때 정확히 오류가 발생합니다.이 논리는 있지만 다른 하나의 프로그램으로이 프로그램을 작성했습니다. 왜 그런지 알지 못해요? 나는이 오류가 왜 누구나 생각이 잘못된 파일 설명 : 프로듀서 파이프 항목을 쓰지 못했습니다? 감사 #define READ

c fork producer-consumer 2017-11-25

---