그래서 나는 한 소비자와 많은 생산자를 Go에서 구현하는 많은 방법을 보았습니다 - Concurrency in Go의 고전적인 fanIn 기능. 내가 원하는 것은 fanOut 함수입니다. 값을 읽는 채널을 매개 변수로 사용하고이 값의 사본을 쓰는 채널 조각을 반환합니다. 이것을 구현하는 올바른/권장 방법이 있습니까?
나는 스레드에 대해 더 많이 배우려고 노력 중이며 생산자/소비자 문제에 대한 해결책을 찾는 것이 좋은 출발이라고 생각합니다. 솔루션에 대한 제약 조건 중 하나는 소비자가 생산자가 얼마만큼 생산하는지 미리 알 수 없다는 것입니다. 코드가 예상대로 실행되고 여러 번 실행했지만 결함이 없음을 의미하지는 않습니다. 이 솔루션에 문제가 있습니까? package Mu
나는 복용하기 전에 헤드 요소를 확인하고 싶어하지만 java.lang.NullPointerException 엿, 가, 어떤 아이디어를 자바 BlockingQueue를 BlockingQueue sharedQueue = new LinkedBlockingQueue()
이 내 코드를 사용하여 제기? 요소가 발견되지 while(true){
try {
.Net3.5에서는 여러 스레드 (적어도 현재는 3 개) 사이의 통신을 작성해야하며 각 스레드는 생산자와 소비자가되어야합니다. 대신 스레드의 각 쌍 사이에 신호를 보내는 나의 생각은 다음과 같이 클래스를 저장할 메시지 큐를 구현하는 것입니다 : enum Signals { ObjectArrivedOnLightBarrier, ObjectLeftLightBarr
유지 보수 중이거나 (많은 코더를 통과 한) 응용 프로그램은 대기/알림 메커니즘을 사용하여 구현 된 프로듀서 - 소비자 문제가 있습니다. 소비자는 응용 프로그램의 "서버"측에서 메시지를 기다린 다음 "클라이언트"측의 메시지를 LDAP 서버로 전달합니다. 여러 연결이 설정/종료되는 문제가 있습니다. 프로듀서 쓰레드는 곱셈을 계속하고 절대로 끝내지 않습니다.
현재 일종의 작업을위한 JPA 엔티티가 있습니다. 일부 프로세스는 해당 테이블에 쓰고 예약 된 프로세스는 해당 작업을 수행하고 준비가되면 상태를 변경합니다. 작업 우선 순위를 정하고 실패 할 경우 빈도를 줄이려면 다시 시도해야합니다. 저의 환경은 Hibernate + MySQL + XA 트랜잭션을 통한 GlassFish 3 + JPA입니다. 중기 적으로 프
노드가 소켓을 통해 메시지 객체를 수신하는 분산 시스템을 사용하고 있습니다. 메시지는 다른 스레드에서 수신 및 처리 될 때 BlockingQueue에 기록됩니다. 한 컴퓨터 내에 단 하나의 BlockingQueue 인스턴스가 있는지 확인합니다. 들어오는 속도는 초당 약 1000입니다. 소비자는 처음에는 잘 작동하지만 특정 기간이 지나면 전혀 응답이 없습니다
저는 리소스 게임 시뮬레이션 프로젝트에 참여하고 있습니다. 내가해야 할 일은 ... "사용 가능한 충분한 리소스가있는 경우 요청이 충족되고 요청 된 수량이 사용 가능한 수량에서 뺍니다. 리소스가 충분하지 않으면 animat는 이용 가능한 양을 확보하고 더 많은 자원을 사용할 수있을 때까지 기다리십시오. " 문제는 예 ... 난 아직도 필요한 것을 어딘가 잡
현재 프로젝트에 JMS를 구현하려고합니다. 메시지 생성자와 메시지 소비자를 두 개의 개별 응용 프로그램으로 만들고 생산과 소비를 두 개의 별도 프로세스 (클라이언트)로 만들고 싶습니다. 하지만 제 요구 사항은 생산자와 소비자간에 트랜잭션 관리를하는 것입니다. 제작자가 100 개의 메시지를 보내고 있고 단일 메시지 전달이 실패하면 전체 100 개의 마사지 배