producer-consumer

1열

1답변

생산자 - 소비자 문제 해결을위한 테스트 작성 방법 _?

연습으로 저는 생산자 - 소비자 문제에 대한 해결책을 구현하고 싶습니다. 배열 int [] 버퍼와 프로듀서와 고객을 각각 시뮬레이트하는 두 개의 메소드 Produce()와 Consume()과 두 개의 메소드를 모두 비동기 적으로 호출하는 하나의 "Execute"메소드가 있다고 가정 해 보겠습니다. 구현이 교착 상태를 일으키지 않을지 테스트하고, 많은 시간

.net multithreading algorithm unit-testing producer-consumer 2013-02-13

---

0열

1답변

BlockingCollection의 IDisposable 대 생산자 소비자

BlockingCollection (코드는 아래 참조)을 기반으로 한 생산자 고객 패턴을 사용하는 간단한 로거가 있습니다. public class Logger { public Logger() { _messages = new BlockingCollection<LogMessage>(int.MaxValue); _worke

c# multithreading producer-consumer 2012-12-27

---

0열

1답변

병렬 루프를 만드는 올바른 방법

나는 Azure 서버에서 일부 데이터를 크런치하는 코드를 작성했다. Parallel.ForEach(users, currentUser => { int number = myrollup.CountFilmsForUsers(currentUser.UserId,distort,tend).Result; lock(myrollup) {

c# nhibernate parallel-processing producer-consumer 2013-01-04

---

4열

1답변

현재 장애가 발생해도 대기열에서 다른 작업을 계속하는 방법은 무엇입니까?

제가 private static void ExecuteOnTaskFailure(Task previousTask) { if (!previousTask.IsFaulted) return; if (previousTask.Exception != null && previousTask.Exception.InnerExceptions !=

c# multithreading task-parallel-library system.reactive producer-consumer 2013-01-14

---

1열

2답변

카프카 0.8이 메시지 레벨로드 밸런스를 달성하는 방법은 무엇입니까?

우리는 카프카 0.8에서 생산자가 사육사와 연결하지 않고 브로커에 직접 연결한다는 것을 알고 있습니다. 요구 사항에 따라 사육사 기반로드 균형을 달성하는 방법보다? 사실, 주제가 작성되면 그 파티션은 하나 이상의 브로커에서 분배됩니다. 메시지를 보내면 해당 키워드에 따라 특정 파티션으로 전달됩니다. 즉, 특정 브로커의 고정 파티션으로 전송해야합니다. 소위로

load-balancing partitioning producer-consumer apache-kafka 2013-01-15

---

1열

2답변

알람 기반 차단 RabbitMQ 제작자를 감지하는 방법?

나는 RabbitMQ 교환기에 내구성있는 메시지를 보내는 생산자가 있습니다. RabbitMQ 메모리 또는 디스크가 워터 마크 임계 값을 초과하면 RabbitMQ가 내 제작자를 차단합니다. 설명서에 따르면 소켓에서 읽는 것을 멈추고 하트 비트를 일시 중지합니다. 내가 원하는 것은 생산자 코드에서 내가 차단되었음을 알 수있는 방법입니다. 현재 하트 비트가 활성

rabbitmq blocking alarm producer-consumer 2013-01-17

---

3열

2답변

Qt 신호/슬롯을 가진 제작자/소비자

여러 제작자가 여러 소비자가 처리해야하는 데이터를 생성하는 프로그램을 작성 중입니다. 각 데이터의 소비에는 약 100ms가 걸리고 대상 플랫폼에는 많은 프로세서가 있기 때문에 각 생산자와 각 소비자가 고유 한 스레드를 얻는 것은 당연합니다. 제 질문은 : Qt 신호/슬롯은 생산자에서 소비자에게 데이터 블록을 전달하는 좋은 방법입니까? 또는 더 나은 솔루션을

c++ multithreading qt signals-slots producer-consumer 2013-01-19

---

1열

2답변

C++의 비동기 함수

서버 역할을하는 클래스 객체가 있습니다. 어느 곳에서나 요청을 받고 요청 큐 (Producer)에 요청을 푸시합니다. 이제는 요청 큐에서 요청을 팝핑하고 해당 클래스 메소드를 호출하여 요청을 제공하는 소비자 스레드가 실행 중입니다. 이제 대기열에서 요청을 소비하고 적절한 기능을 시작하는 것이 동기식으로 실행됩니다. 필자가 원하는 것은 소비자 스레드가 대기열

c++ asynchronous callback boost-thread producer-consumer 2013-01-21

---

1열

2답변

스레드 간 통신

다음 질문은 유니티 게임 엔진에 대한 내용이지만 UI 스레드와 같이 주 스레드로 데이터를 보내려는 프로그램과 관련 될 수 있습니다. 일부 데이터는 별도의 스레드에서 처리 중입니다 (위치 데이터는 소켓과 비동기 적으로 읽음). 그러나, 나는이 데이터를 주 스레드에서 처리해야한다 (게임 개체의 변환은 주 스레드에서만 액세스 할 수있다). 내가 염두에두고있는 접

multithreading unity3d main polling producer-consumer 2013-01-22

---

1열

1답변

생산자 - 소비자 시나리오에서 부스트 조건 변수를 어떻게 사용할 수 있습니까?

편집 : 아래 버퍼의 장치에서 데이터를 스트리밍하는 스레드가 하나 있습니다. 또한, 그 데이터에 대한 처리를 N 개의 스레드가 있습니다. 설치 과정에서 스 트리머 스레드가 장치에서 데이터를 가져오고 새 데이터를 페치하거나 제한 시간에 도달하기 전에 N 스레드가 처리를 마칠 때까지 기다려야합니다. N 스레드는 처리를 계속하기 전에 새 데이터를 가져올 때까지

c++ multithreading boost-thread producer-consumer condition-variable 2013-02-04

---