blockingqueue

0열

1답변

AlarmManager에 의해 트리거 된 PendingIntent에서 정적 BlockingQueue를 수정하십시오.

내 안드로이드 응용 프로그램에는 "전역"응용 프로그램 클래스가 있으며 내부에 정보를 저장하는 정적 BlockingQueue가 있습니다. 대기열이 가득 차면 파일을 플러시합니다. 나는 여러 프로듀서, 서비스, BroadcastReceivers를 가지고 있고 모든 것이 잘 작동한다. 이제는 30 분마다이 BlockingQueue에 쓸 수있는 PendingInt

1열

1답변

Boost_lockFree_SPSC_queue는 실제로 크기가 가변적이며 데이터 손실이 없습니다?

안녕하세요. SPSC 큐를 사용하도록 계획했습니다. 메시지를 대기열에 넣고 새로운 메시지를 다시 기다려야 수신 한 수신 메시지를 항상 청취하는 리스너를 가져야합니다. 대기열의 메시지를 팝업 처리하는 소비자도 있습니다. 청취자가 대기열에 기록하기 위해 잠글 때까지 기다리는 것을 원하지 않기 때문에 나는 boost_lockfree_spsc_queue을 선호했습

0열

1답변

전체 대기열을 사용하는 차단 대기열 동기화를 유지하는 방법

대기열에 요청을 넣는 스레드가 1 개 있고 15 분마다 다른 Cron 작업 (스레드)이 실행되고 모든 요청을 대기열에서 가져 와서 처리를 시작해야합니다. 대기열을 비우십시오. 어떻게이 동기화를 관리하고 시스템에서 요청이 손실되지 않았는지 확인하십시오. 동일한 큐에 대해 Linked Queue를 사용하려고 생각했습니다. 다른 제안을 환영합니다. 나는 자바에

0열

1답변

자바 멀티 스레드 웹 크롤러가 하나의 스레드 만 사용하고 있습니다.

자바에서 첫 번째 웹 크롤러를 쓰려고합니다. 나는 그것이 작동한다고 생각했지만 스레드 세부 사항을 인쇄 할 때 단 하나의 스레드 만 사용되고 있음을 알 수 있습니다. 내가 작업 스레드 (10 개의 스레드 ..하지만 스위치가없는 것처럼 보입니다.)가 시작되었습니다. 또한 출력 (첨부)에서 모든 스레드가 실행되기 전에 URL 처리가 시작되는 것 같습니다. 할

0열

1답변

Java lambdas LinkedBlockingQueue 예기치 않은 동작

람다를 사용하여 만든 thread에서 t linkedBlockingQueue의 요소를 추가하려고합니다. take 메서드를 사용하여 큐를 폴링 할 때 스레드에서 입력 한 마지막 값이 이전 값을 무시한다는 것을 알 수 있습니다. . public List<EntryBarricade> entryBarricades() { List<EntryBarricade

1열

1답변

어떻게 primive 타입을 가진 블로킹 큐를 구현할 수 있습니까?

기본 유형의 차단 대기열을 사용하는 Java 기본 구현이 있습니까? 그렇지 않다면 어떻게 구축 할 수 있습니까? 프리미티브 유형을 사용할 때 boxing 및 unboxing없이 블로킹 큐를 사용하고 싶습니다. 나는 trove 자산을 확인하지만 차단 대기열을 지원하지 않습니다.

1열

1답변

LinkedBlockingQueue를 사용하는 Java Producer/Consumer에서 복제본을 처리합니까?

목록을 처리 할 때 중복 메시지가 표시되는 곳에 linkedblockingqueue가 있습니다. 누구든지이 방법을 사용하여 복제물을 생산할 수있는 방법을 알고 있습니까? 아래는 생성자와 소비자 각각에 대한 큐의 선언과 run() 함수입니다. 한 스레드에서이 작업을 수행 할 때 중복이 발생하지 않습니다. 의미 나는 큐를 사용하지 않고 그냥 UDP 입력에서 읽

2열

1답변

ArrayBlockingQueue : 전역 변수에 직접 액세스하지 않는 이유는 무엇입니까?

ArrayBlockingQueue 구현에서 전역 변수가 직접 액세스되지 않는 이유는 무엇입니까? poll 방법에 public class ArrayBlockingQueue<E> extends AbstractQueue<E> implements BlockingQueue<E>, java.io.Serializable { /** The queu

0열

1답변

BlockingQueue의 소비자 때문에 주 스레드가 멈 춥니 다 (다른 스레드에 있다고 생각했습니다)

차단중인 테스트가 있습니다 (첫 번째 코드 블록). 나는 함께 일하는 몇 가지 요소를 가지고있다. 나는 이벤트를 넣는 블로킹 큐를 가지고있다가, 소비자를 데리고 Amazon Kinesis로 보낸다. 나는 그것이 분리 된 스레드에서 실행 중이라고 생각하더라도 큐가 내 고객을 차단하고 있기 때문에 내 테스트가 차단되고 있음을 확신합니다. 여기 // Test.j

0열

1답변

Stream.generate를 사용하여 단위 테스트 메소드를 작성하는 방법은 무엇입니까?

나는 지난 몇 시간 동안이 코드를 테스트하는 가장 좋은 방법을 알아 내려고 노력했다. void consume() { executorService.execute(() -> Stream.generate(this::takeFromQueue) .filter(Optional::isPresent) .map(Optional::get)