여러 클라이언트 작성으로 순환 버퍼를 작성했습니다 (결국 다른 크기의 메시지를 쓰기를 원합니다). 서버가이를 읽습니다. 그것은 소비자/생산자 문제의 코드를 기반으로 : #include <stdio.h>
#include <malloc.h>
#include <string.h>
#include <pthread.h>
#include <unistd.h>
내 프로젝트에 활성 mq 인터페이스를 구현하는 방법을 배우고 있습니다. 이것이 내가 생산자와 소비자를 만드는 방법이다. public void connectionSetup(String portName) { // portname is object of PortTO class. We are creating producer and consumer pair for
OS 과정을위한 CPU 스케줄링 시뮬레이터 프로젝트를하고 있습니다. 프로그램은 두 개의 스레드, 즉 생산자 스레드와 소비자 스레드로 구성되어야합니다. 생성자 스레드는 시스템에서 프로세스를 생성하는 생성자와 여러 프로세스를 선택하고이를 ReadyQueue 유형의 버퍼 (소비자 및 생산자가 공유 객체)에 넣는 장기 스케줄러를 포함합니다. 소비자 스레드는 큐에서
- 자바에서 소비자의 구현과 내가 나오지 않았어 바퀴를 재발견하고 싶지 않아 새로운 동시성 패키지와 Piped 클래스 중 하나를 사용하는 예제를 찾으십시오 여기에 PipedInputStream과 새로운 Java 동시성 패키지를 모두 사용하는 예제가 있습니까? 그런 작업에 Piped 클래스를 사용하지 않고 더 좋은 방법이 있습니까?
동기화를 올바르게 사용하지 않은 것 같습니다. 나는 아래 출력을 얻는다. 나는 의식적으로 BlockingQueue OR java 5 동시성 기능을 사용하지 않기로 결정했습니다. 동기화와 기본 사항을 배울 수 있도록이 글을 작성했습니다. 생산자 스레드 0-NAME-0 생산자 스레드 : PRODUCER -2- 추가 항목 1 - 이름 - PRODUCER -1-
Classical producer consumer problem. 생산자는 itemCount == BUFFER_SIZE amd가 다운 될 때 다시 깨울 때 잠자 게됩니다. 그러나 itemCount이 커지면 프로듀서 스레드가 잠자기 상태가됩니다. itemCount이 다운되었고 wakeup이 필요하다는 것을 어떻게 알 수 있습니까?
JMS에는 대기열 및 주제가 있습니다. 지금까지는 제작자/소비자 시나리오에서 큐를 가장 잘 사용하고 있으며 게시/구독에 주제를 사용할 수 있습니다. 그러나 제 시나리오에서는 두 가지 접근 방식을 결합하여 생산자 - 소비자 - 관찰자 아키텍처를 만드는 방법이 필요합니다. 특히이 대기열에서 읽은 대기열의 메시지를 처리하고 다른 대기열 (또는 주제)에 기록하는
나는 꽤 바닐라 웹 서비스 (구시대 asmx)를 가지고있다. 메소드 중 하나는 클라이언트에 반환 된 결과와 아무런 관련이없는 비동기 처리를 시작합니다. ThreadPool.QueueUserWorkItem의 DoAsyncStuffHere 방법을 만들어 사용 [System.Web.Services.WebMethod]
public List<Foo> SampleW
Disruptor를 처음 사용했습니다. 다음과 같은 두 가지 쿼리가 있습니다. Q1. one producer to one consumer 및 one producer to multiple dependent consumers의 샘플 코드를 얻었습니다. 여러 소비자의 샘플 코드를 여러 소비자 또는 Sequencer : 3P - 1C에서 얻고 싶습니다. 어떤 블로