java.util.concurrent

-3열

1답변

내가 자바 TimeUnit와를 사용하는 것을 시도하고있다 에 TimeUnit와를 사용하지만 그냥 나에게 오류를 보내는 방법을 그건 내가 Import java.util.concurrent.TimeUnit ; Public class anything { Public static void main(String[ ] args) { System

0열

1답변

Java 8에서 fire-and-forget 요청을 테스트하려면 어떻게합니까?

나는 테스트 할 필요가있는 다른 쓰레드에서 실행되는이 코드를 가지고있다. 여기 내 코드가 있습니다. ExecutorService executor = Executors.newSingleThreadExecutor(); executor.submit(() -> { String partitionKey = format("partition

0열

2답변

CopyOnWriteArrayList (cowal)

하나의 스레드가 반복 목록 일 때 다른 스레드가 기본 목록을 수정할 수 있고 우리는 ConcurrentModificationException (CME)을 얻을 수 없지만 ArrayList의 경우에는 CME를 받으십시오. 하지만 다음 프로그램에는 하나의 스레드 (메인 스레드)가 있지만 여전히 CME를 얻고 있습니다. 왜요? Iterator 때문입니까? AL을

0열

3답변

ScheduledThreadPoolExecutor 동시 작업

이 주제를 많이 연구했지만 유용한 정보를 찾을 수 없습니다. 그리고이 플랫폼에 대한 첫 번째 질문을하기로했습니다. 따라서 특정 기간에 작업을 반복하기 위해 예정된 실행 프로그램을 사용하고 있습니다. 모든 것이 좋습니다. 하지만 오해가 있습니다 .... 내 코드는 작업을 실행하지만 작업이 일정 시간보다 오래 걸리면 작업을 마칠 때까지 기다렸다가 나중에 새 작

0열

2답변

스레드 안전 모드에서 컬렉션을 반복하면서 목록에서 요소 수집

Salesforce fetchSize = 100으로 설정했지만 쿼리에 대해 100 세트의 요소를 가져 오지 않습니다. 따라서 ConsumerIterator의 단일 결과를 목록으로 수집하여 배치 프로세스에 100 개 세트로 전달할 수 있기를 원합니다. 아래 코드가 있습니다. 이것을 올바른 방법일까요? 올바르게 수행하는 방법에 대한 제안은 감사하겠습니다. 50

1열

1답변

자바 중첩 된 큐

업데이트 : 한마디로 , 내가 서비스에 대한 사용자의 메시지를 보내는 큐가 있습니다. 그러나 하나의 서비스가 1000s의 메시지를 받으면 큐보다 이 우세합니다. 큐가 비게 될 때까지 다른 서비스는 메시지를받지 못합니다. 이 접근 방법에 대한 해결책이 필요합니다. BlockingQueue 's에 문제가 있습니다. 내가 그들에게 메시지를 전달할 책임이있는 10

1열

1답변

ExecutorService : 출력이 예상되지 않습니다.

출력을 이해하는 데 어려움이 있습니다. 여기에 집행자를 만든 다음 Runnable 작업을 1000 번 제출하십시오. 예상 출력은 Runable 안에 synchronized을 추가 했으므로 1000입니다. 그러나 실제 출력은 503과 다릅니다. 아무에게도 설명해 줄 수 있습니까? bv public class FutureTest { int count

-2열

1답변

Object가 아닌 Java 동기화 잠금 클래스입니까?

최근에 Bruce Eckel (Java로 생각하기)을 읽었으며 몇 가지 문제점을 발견했습니다. 블록 동기화 (Object) 잠금 클래스! 이 클래스의 객체가 아닙니다. 이 코드는 위에서 언급 한 것으로 증명됩니다. public class Main { public static void main(String[] args) { Sync s

3열

1답변

CompletableFuture와 ListenableFuture의 코 루틴 빌더간에 차이점은 무엇입니까? 코 틀린의 코 루틴의 소스를 검사

동안 나는이의를 제외하고 (거의 동등한 종류의 생각하지만, 나는 JDK 8 CompletableFuture public fun <T> future( context: CoroutineContext = DefaultDispatcher, start: CoroutineStart = CoroutineStart.DEFAULT, block: s

0열

1답변

ConcurrentNavigableMap 3.0.5

내가 mapDB의 최신 버전 (3.0.5)를 사용하고 있는데 나는 이러한 지침이 있습니다 "( DB db = DBMaker.fileDB(new File(FILE_NAME)).closeOnJvmShutdown().make(); ConcurrentNavigableMap<String, Utente> utente = db.getTreeMap("utente");