blockingqueue

    4

    1답변

    take()method을 사용하여 BlockingQueue의 요소에 대해 스레드를 빠는 것이 중단 된 경우를 제외하고 요소를 사용할 수있을 때까지 기다리는 것을 이해합니다. 나는이 두 가지 질문 : I)가 스레드가 자동으로 깨어 업 빨리 요소를 사용할 수있게하거나 지연 (즉, 스레드를 확인 후 자체가)이있는 한? ii) 지연이있는 경우 스레드를 깨우는 것이

    4

    1답변

    LinkedBlockingQueue가 필요하지만 기본 요소를 전달하고 있습니다. 대기열에 추가하는 데이터 속도는 초당 약 4ms 또는 256 데이터 포인트입니다. 내가 겪고있는 문제는 데이터가 시작시 즉시 지연되기 시작하지만 시간이 지남에 따라 JIT가이 작업을보다 효율적으로 수행하고 실시간으로 끝나는 것 같습니다. 나는 초기 지연을 줄이기 위해 어느 위치

    9

    1답변

    누군가 BlockingQueue에서 작업을 가져 오는 일반 스레드를 만드는 대신 "루퍼 (lipe)"기능을 사용하여 "파이프 라인 스레드"를 만들어야하는 이유를 설명 할 수 있습니까? 표면적으로 같은 일을하는 두 가지 방법처럼 보입니다.

    2

    2답변

    나는 다음과 같은 상황이 있습니다 읽기 데이터베이스 의 데이터는 "계산"데이터베이스에 쓰기 결과를 작동합니까 나는 데이터베이스에서 읽은 스레드를 가지고 있으며 생성 된 객체를 BlockingQueue에 저장한다. 이러한 객체는 매우 무거운 가중치이므로 메모리에있는 객체의 양을 제한하는 대기열입니다. 여러 스레드가 큐에서 개체를 가져 와서 작업을 수행하고 두

    9

    2답변

    BlockingQueue에 제공 할 항목이있는 경우 비동기 적으로 알림을 받으려면 Object이 필요합니다. 나는 자바 독과 미리 만들어진 솔루션을위한 웹을 모두 검색 한 , 나는 내의 (어쩌면 순진) 솔루션 결국, 여기있다 : interface QueueWaiterListener<T> { public void itemAvailable(T item

    2

    2답변

    저는 관찰자 패턴과 BlockingQueue를 사용하여 인스턴스를 추가하고 있습니다. 이제 다른 방법으로 나는 큐를 사용하고 있지만, 내가 이런 식으로 일을 해요에도 불구하고, 영원히 대기) (걸릴 것 같다 /** {@inheritDoc} */ @Override public void diffListener(final EDiff paramDiff, fin

    2

    1답변

    BlockingQueue 인터페이스를 테스트하기위한 기존의 JUnit 테스트가 이미 있습니까? 몇 가지 수업을 다운로드하고 프레스 플레이를 한 다음 빨강으로 바뀝니다 (희망적으로 초록색 :-)), 모든 테스트 사례를 하루 동안 생각하지 않아도됩니까? 나는 봤지만 아무것도 찾을 수 없습니다. 몇 가지 아이디어가 있습니까? 편집 :G_H 제공은 기본 디버깅을

    4

    3답변

    자바에서는 BlockingQueue 인터페이스 구현을 유지하는 훌륭한 패키지 java.util.concurrent가있다. 내가 하스켈 비슷한 뭔가가 필요, 그래서 할 수는 큐가 비어있을 때 블록이 시간이-박스 제공 (수) 읽기 작업을 메모리에 큐의 크기를 고정를 유지한다 큐가 비어 있고 타임 아웃 풋 작업에 유사한 을 초과하면 아무 것도 반환하지 않습니다

    2

    4답변

    PriorityQueue에 대한 비슷한 질문을 발견했습니다. 그 오류는 올바르게 초기화되지 않았다는 것입니다. 나도 같은 문제가있을 수 있지만 그것을 올바르게 초기화하는 방법을 알아낼 수 없습니다! 지금부터 난 그냥 수행 BlockingQueue를 myQueue가 = NULL; 하지만 목록에 항목을 추가하려고하면 예외가 throw됩니다. BlockingQu

    2

    1답변

    저는이 문제로 정말 어려움을 겪었으며, 지난 3 일 동안 디버깅을 시도했습니다. 잘만되면 누군가 내가 잘못하고있는 것을 나에게 말할 수있을 것이다. 블로깅을 통해 내 PC에서 스트리밍되는 정보를 수신하기 위해 BlockingQueue (FIFO) 버퍼를 구현 중입니다. RealTerm을 사용하여 하이퍼 터미널 링크를 통해 미리 녹음 된 심전도 신호를 보내고