blockingqueue

5열

2답변

빠른 설명하십시오 내가 BlockingQueues이 스레드 알고 있습니다. 단일 소비자가 소비하기 위해 이벤트를 떨어 뜨릴 수있는 모든 제작자에게 차단 대기열에 대한 단일 참조를 전달할 수 있다는 것을 의미합니까? 그렇지 않으면 일반 업데이트가 있거나 없을 수도 있고 최대 효율을 읽는까지 생성해야하는 것은 극복 할 수없는 작업입니다.

0열

2답변

BlockingQueue.take()로 인해 Java VM이 종료되지 않습니다.

내 응용 프로그램은 blockingQueue를 사용하는 데몬 스레드를 시작합니다. kill -3을 사용하여 죽이면 앱이 완전히 멈추지 않으며 스택 결과는 여전히 BlockingQueue.take()을 기다리고 있음을 보여줍니다. 깨끗한 종료에 도움이 모든 제안을 깊이 ...When it is killed using kill -3, the app doesnt

1열

1답변

메시지가 큐에서 삭제되었습니다.

BlockingQueue 구현을 사용하여 큐의 서비스별로 이벤트를 처리했습니다. 그러나 서버가 다운 된 경우 해당 대기열의 모든 이벤트가 삭제되고 따라서 처리 할 이벤트가 없습니다. (서버가 대기열에서 이벤트/메시지를 저장할 수있는 내부 DB를 찾고 있는데 서버가 다운되고 다시 올라가면 수동으로 개입하지 않고 모든 이벤트/메시지를 다시 처리 할 수 있습

0열

4답변

Java 대기열 차단

차단 대기열에 대해 읽었으며 특정 질문이 표시되었습니다. 내가 읽은 모든 예제는 오직 하나의 소비자와 하나의 제작자 스레드 만있는 상황을 보여줍니다. 질문은 : 우리가 1 명의 생산자와 3 명의 소비자를 가지고 있고 현재 모든 소비자가 take() 메소드로 불려지지만 대기열이 비어있어 모두가 첫 번째 요소를 나타 내기를 기다리고 있다고 가정합니다. 어떤 소

1열

3답변

BlockingQueue 및 대기 스레드 해제 대기

내가 BlockingQueue 있고 일부 스레드 take() 호출됩니다 있지만 큐가 비어있는 순간. 그리고 미래에 새로운 요소가 대기열에 나타나지 않는다는 것을 어떻게 든 알고 있다고 가정 해 봅니다. take() 호출 된 스레드를 대기 상태에서 해제하려면 어떻게해야합니까? 감사! public Order getFromProcessedOrders() thro

0열

1답변

되지 않은 외부 기호

난 내 자신의 블록 큐를 만들었으며 나는 (이 비주얼 스튜디오 2010 년 Qt는 응용 프로그램입니다 주) 링커 오류가 발생 이유를 알아내는 몇 가지 문제에 봉착 : #ifndef BLOCKING_QUEUE_H #define BLOCKING_QUEUE_H #include <QObject> #include <QSharedPointer> #includ

3열

2답변

LinkedBlockingQueue에 중복을 확인하는 방법이 추가되지 않았습니까?

자바 메일 API를 사용하여 여러 Gmail 계정에서 메일을 수신하고 있습니다. 서로 다른 스레드가 다른 계정을 처리하고 있으며 이메일을 저장하기 위해 LinkedBlockingQueue을 사용하고 있습니다. 그러나 나는 동일한 전자 메일이 반복적으로 Queue에 추가되는 것을 원하지 않습니다. 이것은 내가 지금까지 가지고있는 코드 : public sync

1열

1답변

Java ScheduledExecutorService producer \ consumers

다음 프로젝트가 있습니다. 백그라운드에서 Spring (3.2) 기반 웹 응용 프로그램 (Tomcat 7)은 몇 가지 작업이 있습니다. 처리를위한 정보가있는 대기열이 있습니다. 이 대기열은 주기적으로 업데이트됩니다 (비어있는 경우에만). 또한이 큐와 프로세스에서 정기적으로 데이터를 대기열에 포함하는 여러 스레드가 있습니다. 예약하려면 ScheduledExe

3열

3답변

Java의 영구 차단 대기열?

TL; 내가 performitive 그 지속적인 차단 대기열과 lib 디렉토리가 있는지 알아야합니다. 저는 고전적인 프로듀서/소비자 프로그램입니다. 그들은 LinkedBlockingQueue을 공유하여 데이터를 공유하며, 소비자가 새로운 요소를 영원히 기다릴 필요가 있으므로 BlockingQueue#take 메소드를 사용합니다. 문제는 데이터가 많아서 잃을

3열

1답변

BlockingQueue ReentrantLock을 사용하여 구현

연습을 위해 BlockingQueue를 직접 작성했습니다. 메서드에 synchronized 키워드를 사용하지 않으려 고합니다. 대신 ReentrantLock을 사용하고 싶습니다. 이 구현을 작성하는 가장 좋은 방법은 무엇입니까? 저는 Java 닌자가 아니며 누군가 제 코드의 오류를 정확하게 지적하고이를 구현하는 더 좋은 방법을 제안 할 수 있다면 크게 감사