Callable을 Executor에게 제출하여 작성한 Futures 세트가 있습니다. 의사 코드 : for all tasks
futures.add(executor.submit(new callable(task)))
이제 모든 선물이 완성 될 때까지 모든 선물을 기다리고 싶습니다. 나는 내가 Future#get(timeout)라고 부를 수 있다는
주기 : T과 같이 내 애플리케이션에서 수행해야 할 정기 작업이 있습니다. 현재로서는 Timer.scheduleAtFixedRate(TimerTask, 0, T)을 사용하고 있습니다. 이제는 단일 작업의 중복을 피하고자합니다. 어떤 경우에는 단일 작업이 T보다 많은 시간이 걸릴 수 있습니다. 내가 Timer 구현을 읽었습니다 작업을 실행하는 단일 스레드를
DB 용량을 초과하면 생성되는 코드에 스레드 정리 도구가 있습니다. DB에 삽입 할 때마다 용량이 검사됩니다. 이 클리너에 더 많은 기능을 추가하고 파일 수가 많으면 10000 개의 파일을 정리하고 싶습니다. 새 기능이 예정대로 실행되어야합니다. DB를 두 가지 방법으로 정리할 수 있습니다. 1. 주문형입니다. 2. 매일 X 시간으로 예약됩니다. 어떤 동시
ConcurrentHashMap을 사용하는 레거시 응용 프로그램이 있습니다. concurrentHasMap은 순서가 매겨지지 않았지만 처음 삽입 된 객체를 읽는 것은 필수 조건입니다. 내가 가지고있는 코드는 제작 중에 언젠가 존재 해왔고 따라서 컬렉션을 대체하기위한 빠른 대안을 찾고 있으며 주문도 줄 수 있습니다. 기본적으로 최소 코드 변경으로 이어지는 매
자바에서 포크 - 조인 기술을 배우고 다음 프로그램을 작성했습니다. 나는 for 루프 (5 번)를 실행 중이며 for 루프의 내용을 별도의 스레드로 실행하려고합니다. 이것은 올바르게 일어나고 있습니다. 문제는 모든 스레드가 완료되면 크기 5의 벡터가 필요하며 인덱스 1에 스레드 1을 실행 한 결과를 포함해야하며 인덱스 1에 스레드 2를 실행 한 결과가 포함
: 우리가 코멘트에 작성된 쓰기 잠금을 획득하기 전에 읽기 잠금을 해제해야하는 이유 void processCachedData() {
rwl.readLock().lock();
if (!cacheValid) {
// Must release read lock before acquiring write lock
5: rwl.readLoc
위 제목이 내 주요 관심사입니다. 그리고 경우는 public class MyClass{
CopyOnWriteArrayList<Stuff> min;
...
public List<Stuff> get(){
return min;
}
}
get()에서 얻은 목록은 책임이 있습니까? min에 영향을 미치 나 자체 복사
블록 아래에 try 블록 아래에는 3 개의 명령문이이 순서대로 실행되어야합니다. 진술서가 작동하지 않을 가능성이 있습니까? JVM이 동기화 표시기 (동기화 된, 휘발성)를보기 위해 j.u.c 클래스를 살펴보고 실행 순서를 변경해서는 안된다는 것을 알 수 있습니까? private Deque<Integer> deque = new LinkedList<Intege
많은 스레드가 컬렉션을 공유해야하고 스레드가 컬렉션에서 쓰기를 계속해야하는 시나리오가 있는데 비교적 쓰기가 많고 읽기가 매우 적습니다. 확실하지 않습니다 ArrayBlockQueue는 사용할 올바른 컬렉션입니다. 내 컬렉션을 구현해야합니까, 아니면 Java로 상자 밖의 것을 얻을 수 있습니까? 도와주세요.
MQ 인프라에서 가져온 일부 메시지를 처리하려고합니다. sharedQueue 및 pubQueue 두 개의 차단 대기열이 있습니다. sharedqueue은 아래와 같이 MQ 인프라에서 가져온 메시지로 채워집니다. 메시지를 sharedQueue에 넣습니다. client.setCallback (새 CallBack ("inst", sharedQueue)); mes