을 작업을 사용하여 차단하는 동안 몇 가지 작업이 (nWorkers = 3) : var taskFactory = new TaskFactory(cancellationTokenSource.Token, TaskCreationOptions.LongRunning, TaskContinuationOptions.LongRunning, TaskScheduler.Defaul
개체 (예 : 문자열)를 생성하는 스레드와 개체를 사용하는 단일 스레드 (예 : 원격 서버를 직렬화하고 원격 서버를 보내는)가 있습니다. 제작자가 가능한 한 빨리 데이터를 피할 수 있기를 바랍니다. 그들은 소비자가 아닌 다른 생산자 때문에 절대 절대로 안됩니다. 이것이 가능한가? 방법?
나는 다음과 같은 코드를 가지고있다. 각 제작자에 대해 하나의 대기열. 소비자는 모든 대기열을 반복하며 소비 할 작업이 있는지 확인합니다. 그가 검사중인 대기열에 작업이 있으면 소비합니다. 그렇지 않으면, 그는 모든 대기열에 대해 반복 작업을 완료 할 때까지 다음 대기열을 확인합니다. 지금까지 모든 대기열을 반복하여 모두 비 었으면 그는 그 중 하나에 무언
두 개의 .net 응용 프로그램간에 동일한 BlockingCollection을 공유하는 방법이 있습니까? 하나의 응용 프로그램이 새 항목을 생성하고 다른 응용 프로그램이이를 사용하는 중입니까? 내가 발견 한 프로세스 간 통신 옵션에는 데이터 직렬화 및 비 직렬화가 포함되어있는 것처럼 보입니다. 따라서 한 프로세스에서 다른 프로세스로 BlockingColle
SOA 응용 프로그램에서 다음과 같은 시나리오가 있습니다. ServiceA는 ServiceB의 인스턴스에 의해 비동기 적으로 처리되어야하는 일부 작업을 생성합니다. 기본적으로 이는 각 작업자가 ServiceB의 인스턴스 인 작업 대기열 문제로 변환됩니다. 우리는 메시지 브로커로 Kafka를 사용하고 있으며 다음과 같은 설정을합니다. 5 브로커 B1, B2,
다중 소비자 또는 병렬 소비자로 생산자/소비자 패턴을 구현하려고합니다. 구현을했는데 얼마나 좋은지 알고 싶습니다. 누군가 더 잘할 수 있습니까? 어떤 오류라도 발견 할 수 있습니까? 불행히도 저는 TPL 데이터 흐름을 사용할 수 없습니다. 왜냐하면 우리는 프로젝트가 끝났기 때문에 패키지에 추가 라이브러리를 넣을 때 많은 서류 작업이 필요하고 그 시간이 필요
안녕하세요 메신저 VM웨어를 사용하여 우분투 가상 이미지에 생산자/소비자 문제를하려고합니다. 나는 여기에서 코드를 가지고있다 : http://macboypro.wordpress.com/2009/05/25/producer-consumer-problem-using-cpthreadsbounded-buffer/하지만 나는 계속 "segmentation fault
통지 생산자 소비자 설정 밖으로 종료 : // 프로듀서 public boolean busy = false;
while (rst != null && rst.next()) {
while (queue.size() == 10) {
synchronized (queue) {
try {
log.debug("
을위한 멀티 스레딩 : 구축 중 하나 Stream 또는 Iterator 그 게으르게 요소를 생성합니다. 또는 foreach을 Stream 또는 Iterator에서 처리하여 이러한 요소를 처리하십시오. 이것은 잘 작동하는 것처럼 보이지만 단일 스레드처럼 보입니다. 새 요소를 처리하려고 할 때 생성되도록 요청하고 생성 된 후에 작업을 시작합니다. 그것. 제가
동일한 컴퓨터에 제작자와 브로커가 있습니다. 생산자는과 같이 메시지를 보냅니다 : channel = connection.createChannel();
//Create a durable queue (if not already present)
channel.queueDeclare(merchantId, true, false, false, null);
/