blockingqueue

7열

3답변

처리 파이프 라인을 구현하는 가장 좋은 방법과 씨름하고 있습니다. 내 제작자가 BlockingQueue에 작업을 제공합니다. 소비자 측에서는 큐를 폴링하고, Runnable 태스크에서 얻은 것을 랩 한 다음 ExecutorService에 제출합니다. while (!isStopping()) { String work = workQueue.poll(1

1열

1답변

소켓에서 줄을 읽어서 BlockingQueue에 넣는다.

누구나 자바로 예제를 제공하거나, 소켓에서 비동기 적으로 줄을 읽고 각 줄을 BlockingQueue에 넣는 클래스를 구현하는 것에 대한 조언을 할 수있다. 소켓이 연결되어 있고 BlockingQueue 및 소비자가 이미 있다고 가정합니다. 편집 : 한 가지 더, 일정 기간 사용하지 않으면 타임 아웃하고 명령을 즉시 중지 할 수 있어야합니다. 숙제가 아니기

0열

3답변

Java - LinkedBlockingQueue 문제

1 LinkedBlockingQueue queJobs = new LinkedBlockingQueue(150); 2 .......... 3 .. Some other code.... 4 .......... 5 Job curJob = queJobs.take(); 6 .................... 7 .

3열

1답변

단일 스레드 내에서 여러 BlockingQueues를 읽는 중

세 개의 Java LinkedBlockingQueue 인스턴스가 있는데 한 스레드 만 사용하여이 인스턴스를 읽으 려합니다 (take 작업). 순진한 접근 방식은 큐당 하나의 스레드를 갖는 것입니다. Java의 대기열 차단을위한 UNIX select 시스템 호출과 같은 것이 있습니까? 감사합니다.

5열

2답변

Re-largeable Java BlockingQueue

그래서 생산자/소비자 유형 응용 프로그램에서 고정 크기 BlockingQueue [ArrayBlockingQueue]를 사용하고 있지만 사용자가 대기열 크기를 즉시 변경할 수있게하려고합니다. 문제는 생성 후 용량을 변경할 수있는 BlockingQueue 구현이 없다는 것입니다. 누구든지 전에 이것을 보았습니까? 어떤 아이디어?

27열

6답변

java BlockingQueue에 블로킹 픽이 없습니까?

개체 차단 대기열이 있습니다. 대기열에 개체가있을 때까지 차단하는 스레드를 작성하고 싶습니다. BlockingQueue.take()가 제공하는 기능과 유사합니다. 그러나 개체를 성공적으로 처리 할 수 있는지 여부를 알 수 없으므로 개체를 제거하지 않고 peek()을 수행하고 싶습니다. 내가 성공적으로 처리 할 수있는 경우에만 개체를 제거하고 싶습니다

1열

2답변

차단 우선 순위 큐에 저장된 사용자 정의 개체 업데이트

Message 유형의 개체를 저장하는 차단 우선 순위 큐가 있습니다. 메시지에 String [] data = new String [10]이 있습니다. 이제 전체 Blocking Queue에 대해 반복 작업을 수행해야합니다. Object 메시지의 두 번째 요소가 들어오는 메시지의 여섯 번째 요소와 같은지 확인하십시오. 메시지 비교기는 업데이트해야 할 여섯 번

12열

4답변

변수 지연이있는 ScheduledExecutorService

java.util.concurrent.BlockingQueue에서 요소를 가져 와서 처리하는 작업이 있다고 가정합니다. public void scheduleTask(int delay, TimeUnit timeUnit) { scheduledExecutorService.scheduleWithFixedDelay(new Task(queue), 0, de

6열

3답변

C++ pthread 블로킹 큐 데드락 (내 생각 엔)

pthreads에 문제가 있는데 어디서 교착 상태에 빠졌다고 생각합니다. 내가 생각했던 차단 대기열을 만들었지 만, 더 많은 테스트를 한 후에 blocking_queue에서 차단중인 여러 스레드를 취소하려고하면 교착 상태가 발생하는 것으로 나타났습니다. 블로킹 큐는 매우 간단하며 다음과 같습니다 template <class T> class Blocking_

2열

1답변

자바 프로세스에서 수천 개의 스레드가 생성 ... 왜?

Java 프로세스를 실행할 때 Linux (64 비트) 로의 최근 고객 마이그레이션에 문제가 있습니다. 프로세스는 futex 식별자를 사용하여 수천 개의 스레드를 생성합니다. 나는 futex (빠른 사용자 공간 뮤텍스)를 찾았으며 기본 잠금을 구현하는 Linux 구조이다. 코드는 최근에 하위 스레드를 생성하기 위해 BlockingQueue 및 Executo