blockingqueue

1열

2답변

java.util.concurrent.BlockingQueue에 대한 술어 (/ find/search)가 들어 있습니까?

java.util.concurrent.BlockingQueue 편리한 contains 방법이있다하십시오 predicate/검색 기준을 적용 : /** * Returns {@code true} if this queue contains the specified element. * More formally, returns {@code true} if and

java queue blockingqueue 2017-03-29

---

1열

1답변

사용자 지정 LinkedBlockingQueue 교착 상태

ThreadExecutorPool 안에 사용자 지정 blockingqueue를 사용하고 있지만 작업 근로자가 작업을 수행하지 않고 dispissher 스레드가 새 작업을 큐에 넣지 않는 경우가 있습니다. 다음 사용자 지정 차단 대기열 구현으로 인해 교착 상태가 발생합니다. 이 코드에 문제가 있습니까? add() 및 take() 방법에 대해서는 synchro

java deadlock blockingqueue 2016-12-21

---

0열

2답변

정상적으로 BlockingQueue에서 작업 작업을 완료하는 방법 java

BlockingQueue 및 ExecutorService를 사용하여 작업 대기열을 작성하고 있습니다. 그것은 기본적으로 대기열에 새 데이터를 기다리는 중입니다, 어떤 데이터가 대기열에 넣어면 executorService는 대기열에서 데이터를 가져옵니다. 하지만 문제는 내가 루프를 사용하여 데이터를 가지고 대기열을 기다리고 따라서 CPU 사용량이 매우 높다는

java executorservice blockingqueue 2017-04-05

---

4열

1답변

PriorityBlockingQueue에서 잠금/잠금 해제 추론은 무엇이 될 수 있습니까?

나는 자바에서 source code of PriorityBlockingQueue을 읽고하고 궁금 해서요 : 가 왜 tryGrow()() 방법, 바로 그 일이 비 제공하는 동안 획득 한 잠금을 해제 방법을하는 것입니다 차단 한 다음 대기열의 내용을 바꿀 준비가되면 다시 차단 하시겠습니까? 내 말은, 그것이 방금 가지고 있던 자물쇠를 지킬 수 있었음을 의미합니

java multithreading blockingqueue 2016-12-27

---

3열

1답변

LogWriter의 경쟁 조건으로 인해 제작자가 차단 될 수 있습니까? [연습 동시성]

우선 읽는 것을 좋아하지 않는 녀석들에 의한 마크 질문을 막기 위해 나는 Producer-Consumer Logging service with Unreliable way to shutdown 질문을 읽었다. 그러나 질문과 대답이 책 본문과 모순되는 것에 대해서는 완전히 대답하지 않습니다. 이제 우리는이 프로세스를 중지하는 방법을 이해하기 위해해야 ​​ pu

java multithreading concurrency shutdown blockingqueue 2017-02-21

---

1열

1답변

Java - 단일 스레드 실행자

여러 생성자와 단일 소비자 (항목의 사후 처리에 충분 함)가있는 차단 대기열이 있습니다. 프로듀서는 실행 프로그램 풀로 작업을 보내고 대기열에 작업자가 작업을 추가하는 일정에 따라 시작됩니다. 소비자 스레드를 시작하는 방법에 대한 제 질문. 지금은 나는 루프, 어쩌면 더 나은 솔루션이 경우에 존재하는 동안 무한으로 큐를 제공 singleThreadExecu

java spring multithreading architecture blockingqueue 2017-10-31

---

0열

1답변

프로듀서 컨슈머 (consumer) 시나리오. 실행이 완료 할 때까지 큐로부터 읽는 것을 정지한다.

나는 BlockingQueue를 사용하여 프로듀서 소비자 시나리오를 구현 중이다. 이 내 소비자 방법을 실행하는 것입니다 : @Override public void run() { try { Message msg; System.out.println("Consumer started"); //consumi

java queue producer-consumer blockingqueue 2017-04-19

---

2열

1답변

ros :: spinOnce()가 특정 콜백 수를 콜백 대기열에서 호출하도록하는 방법이 있습니까?

나는 각 콜백 함수 후에 특정 계산을 수행해야하는 ROS 프로그램을 작성 중이다. 내 콜백 함수는 기본적으로 주제를 구독하고 특정 계산을 수행하는 데 사용되는 변수의 값을 설정합니다. 구독하고자하는 주제에는 30Hz의 주파수가 있습니다. 그래서, 30 Hz의 속도로 실행되는 내 프로그램에서 while 루프가 있습니다. 루프는 다음 코드와 다소 비슷하다 wh

callback ros blockingqueue 2017-01-12

---

0열

1답변

큐에서 표현

은 내가이 정말 큐의 사용 사례 아니라는 것을 알고, 이제 난 단지 특정 객체를 큐에서 제거 할 상황이 Blocking QueueMarc Gravell's에 따라 차단 큐 클래스가 어디에와 대기열에서, 그러나 어떤 경우에는 이것이 좋은 확장이라고 생각합니다. 예를 들어 특정 네트워크 응답을 기다리는 것과 같습니다. 이이 문제는 내가 특정 개체에 대기하고 차

c# queue mutex blockingqueue 2017-11-08

---

1열

2답변

Spring TaskExecutor 프레임 워크에서 스레드를 관리하는 방법

BlockingQueue은 Runnable입니다. TaskExecutor 구현 중 하나를 사용하여 모든 작업을 간단하게 실행할 수 있으며 모두 병렬로 실행됩니다. 그러나 일부 Runnable은 다른 사람에 따라 다르므로 Runnable이 완료 될 때까지 기다려야한다는 것을 의미하므로 실행될 수 있습니다. 규칙은 매우 간단합니다 : 모든 Runnable 코드

java spring multithreading blockingqueue 2017-03-10

---