blockingqueue

6열

3답변

BlockingCollection 대기열이 백그라운드 스레드에 의해 지워질 때까지 기다리십시오. 시간이 오래 걸리면 시간 초과가 발생합니까?

C#에서는 BlockingCollection이 백그라운드 스레드에 의해 지워질 때까지 기다릴 수 있는지 궁금합니다. 시간이 오래 걸리면 시간 초과가 발생합니다. 나는 순간이 임시 코드는 나에게로 다소 세련되지 못한 파업 (Thread.Sleep를 사용하는 것이 좋습니다을 때부터?) : while (_blockingCollection.Count > 0 ||

c# .net blockingqueue blockingcollection 2014-01-07

---

0열

4답변

두 개의 서로 다른 객체에 대한 액세스 동기화

객체를 검색해야합니다 (먼저 BlockingQueue에 있음). 해당 객체가없는 경우 ConcurrentHashMap에서 검색해야하며 일부 작업을 수행해야합니다. 이것은 스레드로부터 안전해야합니다. 아래 코드는 정상입니까? ConcurrentHashMap에서 동기화가 예상대로 작동합니까? synchronized(blockingQueue){ if(!

java synchronization concurrenthashmap blockingqueue 2013-08-20

---

1열

2답변

BlockingQueue에서 차단 된 스레드

BlockingQueue 용량 1입니다.받은 재고의 최종 가격을 저장합니다. 클라이언트가 큐를 폴링 할 때까지 가격은 큐에 남아 있습니다. 그런 다음 getLatestPrice()이라는 메서드를 사용하여 최신 가격을 반환해야합니다. 내 문제는 클라이언트가 아직 폴링하지 않은 경우 최신 가격이 대기열에 없을 수 있다는 것입니다. 차단 된 스레드에있을 수 있습

java multithreading blockingqueue 2014-01-19

---

0열

1답변

소켓 setReceiveBufferSize에 의지하거나 BlockingQueue를 사용합니까?

내 소켓으로 많은 양의 데이터를 읽는 것을 의미하는 응용 프로그램을 만들고 있습니다. 내가 가지고있는 문제는 소켓의 setReceiveBufferSize에 의존해야한다면, 내가 처리 할 수있을 때까지 가지고있는 모든 데이터를 모으거나, BlockingQueue를 사용하여 거기에 모든 것을 처리 한 다음 풀링 및 데이터 처리를 유지하는 다른 스레드에서 처리합

sockets blockingqueue 2013-08-25

---

2열

2답변

멀티 스레드 방식으로 다른 클래스의 같은 메서드를 호출하는 방법

CLASS-A and CLASS-B의 두 클래스에 process이라는 메서드가 있습니다. 이제 아래 루프에서 두 클래스 중 하나를 순차적으로 의미하는 process method이라고 부르겠습니다. 제대로 작동하지만 그것이 내가 찾는 방법이 아닙니다. for (ModuleRegistration.ModulesHolderEntry entry : ModuleReg

java multithreading threadpool executorservice blockingqueue 2013-08-27

---

0열

2답변

BlockingQueue의 사용

코드에 큐를 사용하려고합니다. 핵심은 파일의 총 단어 수를 출력하기를 원한다는 것입니다. 즉, 완료 될 때 모든 결과를 함께 추가해야 할 필요가 있음을 의미합니다. 현재 내 프로그램은 파일을 통해 실행되는 독자가 있으며 파일 이름과 단어의 양을 나타내는 문자열을 반환합니다. 그런 다음 args 배열에있는 각 인수에 대해 for 루프를 실행하기 위해 main

java blockingqueue 2013-12-07

---

0열

2답변

Java의 대기열에 대한 간단한 대답이 필요합니다.

ArrayBlockingQueue를 사용하려고하지만 올바른 구문을 얻지 못하는 것 같아 사용하기 위해 가져온 항목을 정확히 알지 못합니다. 선언에 대한 BlockingQueue<int> Queue = new ArrayBlockingQueue<int>(100); 하지만 int 치의 모두 INT "이 토큰 후 예상 크기"에 오류가 있음을 말한다 : 나는 이

java queue blockingqueue 2014-01-31

---

2열

2답변

C++ 블로킹 큐 Segfault 승격

시간 초과 가능 offer()과 함께 C++의 블로킹 큐가 필요했습니다. 대기열은 인 복수의 생산자 을 대상으로합니다. 이전에 구현할 때이 필요에 맞는 기존의 대기열을 찾지 못해서 직접 코딩했습니다. 대기열의 take() 메소드에서 나오는 segfaults가 표시되지만 간헐적 인 것입니다. 문제에 대한 코드를 살펴 봤지만 문제가있는 것으로 보이지 않습니다.

c++ multithreading boost blockingqueue 2013-10-29

---

1열

1답변

생산자 - 소비자 시나리오에서 많은 제작자와 LinkedBlockingQueue 스레드 안전성

많은 제작자 (적어도 2 명)가 고정 된 비율로 동일한 LinkedBlockingQueue에 액세스하는 Java 상황을 모델링하려고합니다. 그들은 다시 생산하고, 다시 시작합니다. 이것이 결국 큐에서 쓰기 액세스를 얻으려는 프로듀서 간의 경쟁 조건으로 이어질 수 있는지 궁금합니다. java.util.concurrent.BlockingQueue의 구현물이 이

java concurrency race-condition producer-consumer blockingqueue 2014-02-10

---

0열

2답변

두 대기열에서 통화가 차단 되나요?

나는 우선 순위를 적절하게 관리 할 수 ​​있도록 여러 대기열에서 데이터를 읽는 알고리즘 (VxWorks의 작업)을 가지고 있습니다. 이제 msgQReceive() 함수는 WAIT_FOREVER으로 설정되어 수신 및 처리가 가능해질 때까지 차단 호출이됩니다. 이제 다중 대기열이있는 경우 어떻게해야합니까? 현재 어떤 큐가 어떤 내용을 가지고 있고 그것들을 받

optimization resources queue vxworks blockingqueue 2014-02-13

---