나는 BlockingQueue를 사용하여 프로듀서 소비자 시나리오를 구현 중이다. 이 내 소비자 방법을 실행하는 것입니다 : @Override
public void run() {
try {
Message msg;
System.out.println("Consumer started");
//consumi
메신저 카프카 작업 첫번째 초에 메시지를 생성하는 속도가 느린이며, 나는 그런 프로듀서 만든 : 당신이 매우 간단 볼 수 synchronized (obj) {
while (true){
long start = Instant.now().toEpochMilli();
for (int i=0; i< NUM_MSG_SEC ; i
현재 코드가 생산자 소비자 질문에 대답하지만 다른 방식으로 구현하려고합니다. 전역 변수를 사용하여 버퍼 스택의 카운트를 추적하고 싶지 않습니다. 내 사고 과정은 어떻게되어야합니까? typedef int semaphore;
semaphore mutex, full, empty;
int count = 0;
union semun {
in
대기열에 저장된 요소의 컨테이너로 std :: vector를 사용하고 스레딩/동기화에 Boost를 사용하여 다음과 같은 블로킹 대기열 구현을 생각해 냈습니다. 나는 또한 유사한 게시물 here을 언급했다. template<typename T>
class BlockingQueue
{
public:
explicit BlockingQueue(con
하나의 제작자와 여러 소비자에 대해 코드를 실행하고 있습니다. 소비자 스레드의 실행 우선 순위를 지정하려고합니다. ie consThread1, consThread2, consThread3이있는 경우. 내 질문에 consThread1 및 consThread2 Producer.java import java.util.concurrent.BlockingQueue;
나는 두 개의 생산자와 두 명의 소비자를 만들었고 producer1은 consumer1에 두 개의 정수를 보내고 consumer1은 숫자의 합을 출력하고 또 다른 소비자와 생산자는 producer2에게 consumer2에게 폴더의 경로를 보내고 consumer2는 모든 파일을 디렉토리에서 출력했다. (리눅스에서 ls 명령). 이제는 이것을 병합하고 싶습니다
나는 boost :: asio를 사용하여 HTTP 서버를 작성하고있다. 대용량 파일의 경우 전체 파일을 메모리로 읽어 들이지 않고 네트워크로 보내는 것을 피하기 위해 boost :: asio :: async_write를 사용하여 네트워크에서 보내는 부분별로 읽습니다. 문제는 제작자 (파일에서 읽는 함수)가 소비자 (boost :: asio :: async_
클래식 프로듀서 소비자 프로그램. 현재 대기열이 비어있는 경우 소비자 대기를 시도합니다. 큐는 메모리에있는 구조체입니다. 내 pthread_cond_wait() 함수에 문제가 있습니다. 전역 변수는 허용되지 않으므로 pthread_cond와 뮤텍스를 큐 구조체의 메모리에 저장합니다. pthread_cond_wait()는 정수 6을 condWaitCheck에
동기화 된 블록을 이해하려고합니다. 여기서는 하나의 제작자 스레드와 2 개의 소비자 스레드를 구현했습니다. LinkedList가 비어있어 스레드에서 예외가 계속 발생합니다. package com.Main;
import com.qed.Consumer;
import com.qed.Producer;
import com.qed.Store;
public