blockingqueue

0열

1답변

C#의 blockingqueue에서 현재 실행중인 작업을 얻는 방법?

나는 현재 실행중인 작업을 얻고 싶다. 내가 blockingqueue에 추가하는 작업은 어떻게 할 수 있는가? 편집 :이 우선 순위 스케줄러를 사용하고 서로 다른 우선 순위 여러 작업을 추가하고 : 나는 중지하고, 예를 들어이 우선 순위에 따라 작업을 재개 할 public class PriorityScheduler : TaskScheduler {

c# task-parallel-library blockingqueue 2012-10-05

---

1열

1답변

폴링이 LinkedBlockingQueue에서 다른 작업을 차단합니까?

아래의 의사 코드에서 나는 주 스레드에서 영원히 호출되는 poll() 함수를 가지고 있습니다. poll()에 sleep() 문없이이 작업을 수행하면 다른 스레드가 1 분에 2-3 개의 항목 만 대기열에 추가됩니다. 이것은 폴링이 put() 성명을 차단한다는 것을 의미합니까? 이 문제를 어떻게 해결할 수 있습니까? public class Test extend

java multithreading blockingqueue 2012-05-14

---

1열

2답변

BlockingQueue java, Storm (분산 컴퓨팅) 구현에 문제가 있습니까?

이것은 클러스터를 통해 스트림을 처리하기 위해 정당화 된 처리에 튜플을 생성하는 데 필요한 입력 포트의 코드 스 니펫입니다. 문제는 BlockingQueue가 InterruptedException을 던지고 있다는 것입니다. 비동기 인터럽트 루프 -가 가 가 가 java.lang.InterruptedException10930 [스레드 (20)] 정보는 bac

java apache-storm blockingqueue 2012-07-05

---

0열

2답변

소비자 필터링을 사용하는 생산자 - 소비자 차단 대기열

java에 생산자 - 소비자 패턴을 쓰려고합니다. 나는 일련의 서로 다른 연결을 통해 많은 서버에 연결된 네트워크 클라이언트입니다. 서버는 다양한 '작업'패킷을 생성하여 모두 하나의 차단 대기열에 저장합니다. 내가하려는 것은 특정 유형의 작업 패킷 만 특정 소비자에게 전달되도록 소비자를 차단하는 것입니다. 예 : 블로킹 큐 작업 패킷 객체들의 세 가지 유형

java producer-consumer blockingqueue 2012-07-10

---

3열

1답변

동시 응용 프로그램에서 "예측할 수없는 LinkedBlockingQueue 성능"의 의미는 무엇입니까?

내가 작업하고있는 로깅 기능에 대해, 작업 대기를 기다리고 특정 수에 도달하거나 초과하면 일괄 적으로 실행하는 처리 스레드가 있어야합니다. 생산자 소비자 문제의 표준 사례이므로 BlockingQueues을 사용하려고합니다. 두 번째 생산자가 add() 메서드를 사용하여 대기열에 항목을 추가하는 반면, take()을 사용하여 대기열에서 대기하는 소비자 스레드

java concurrency producer-consumer blockingqueue 2012-08-30

---

2열

3답변

항목을 결합 할 수있는 효율적인 BlockingQueue 구현은 무엇입니까?

엔트리의 결합을 허용하는 java.util.concurrent.BlockingQueue의 효율적인 (모든 것을 동기화하지 않고) 구현이 있습니까? 결합하면받는 항목을 대기열에있는 기존 "동일"항목 (있는 경우)과 병합합니다. 그렇지 않으면 평소와 같이 항목이 마지막에 추가됩니다.

java blockingqueue merging-data 2012-07-16

---

2열

3답변

BlockingQueue 대 Semaphore

데이터베이스 연결 풀과 같은 리소스 풀을 구현하려는 경우. 어떤 동시 수집을 사용 하시겠습니까? BlockingQueue 또는 Semaphore? 생산자 - 소비자 디자인 패턴과 마찬가지로 BlockingQueue의 경우 생산자는 모든 연결을 대기열에 배치하고 소비자는 대기열에서 다음에 사용 가능한 연결을 취합니다. Semaphore의 경우 세마포어를 풀

java multithreading concurrency semaphore blockingqueue 2012-09-04

---

3열

3답변

자바 애플리케이션을 C++ (Qt)로 이식하기

저는 Swing을 사용하여 Java로 애플리케이션을 작성했으며 이제는 C++로 다시 작성하려고합니다. Java의 프로그램에는 Controller에 대한 Model, View 및 BlockingQueue에 대한 참조가있었습니다. View에서 새로운 이벤트가 발생하면 BlockingQueue에 새 이벤트가 입력되고 컨트롤러 및 모델에 의해 처리됩니다. Swin

java c++ model-view-controller qt blockingqueue 2012-05-31

---

1열

1답변

생산자 소비자 자바

에서 나는 다음과 같은 코드를 작성했지만, 내가 잘못 어딘가에 갈거야 느낌 : 여기 public class ProcessQueue { static BlockingQueue<String> queue = new LinkedBlockingQueue<String>(); public ProcessQueue() { process(); } publ

java producer-consumer blockingqueue 2012-04-13

---

14열

4답변

Java BlockingQueue with batching?

Java BlockingQueue와 동일한 데이터 구조에 관심이 있습니다. 단, 큐의 객체를 일괄 처리 할 수 ​​있어야한다는 점이 다릅니다. 즉, 생산자가 객체를 대기열에 넣을 수 있지만 대기열이 특정 크기 (배치 크기)에 도달 할 때까지 소비자 블록을 take()에 두는 것이 좋습니다. 큐가 배치 크기에 도달하면 생산자는 대기열의 모든 요소를 ​​소비

java queue producer-consumer blockingqueue 2012-02-27

---