Batch 인터페이스 요청의 순서를 보장하고 결과를 효율적으로 처리하기 위해 완성 가능한 문제를 사용하는 방법은 무엇입니까?

Java 동시 프로그래밍 : Batch Interface 요청을 효율적이고 순서대로 처리하려면 완성 장치를 사용하십시오.

타사 인터페이스에 대한 동시 액세스가 높은 데이터 처리 효율성을 크게 향상시킬 수 있지만 스레드 실행 순서가 제어되지 않으면 최종 결과가 원래 데이터 순서와 일치하지 않아 후속 처리 오류가 발생할 수 있습니다. 이 기사에서는 Java의 완성 가능한 문제를 사용하여 인터페이스 요청을 순서대로 처리하고 다중 스레드 환경을 초래하는 방법을 소개합니다.

문제 : CompletableFuture.runAsync 직접 사용하여 비동기 호출을합니다. 예측할 수없는 스레드 실행 순서로 인해 반환 된 결과는 원래 데이터 목록의 순서와 일치하지 않습니다. CompletableFuture.allOf 모든 작업의 ​​완료 만 보장 할 수 있으며 주문을 보장 할 수는 없습니다.

솔루션 : CompletableFuture.supplyAsync 를 사용하여 결과를 반환합니다. 각 비동기 작업의 반환 결과를 CompletableFuture<string></string> 에 저장하십시오. CompletableFuture<string></string> 목록에서 모든 작업이 완료된 후 결과는 stream().map(CompletableFuture::join).collect(Collectors.toList()) .

개선 된 코드 예 :

 public static void main (String [] args) {
    목록<string> Datalist = New ArrayList  (); // 원래 데이터 목록 // ... Datalist 초기화 ...

    executorService executorService = new ThreadPooleExecutor (
            10, // corepoolsize
            20, // maximumpoolsize
            60L, // KeepaliveTime
            TimeUnit.seconds,
            새로운 LinkedBlockingqueue  (1024), // Workqueue
            새로운 ThreadPoolexecutor.callerrunspolicy () // 핸들러
    );

    목록 <completablefuture> > futures = new ArrayList  ();
    (문자열 데이터 : Datalist) {
        futures.add (wempletablefuture.supplyAsync (() -> {
            logger.info ( "처리 데이터 : {}", 데이터);
            // 데이터를 처리하려면 타사 인터페이스를 호출합니다
            // ... 인터페이스 호출 및 결과 처리 로직 ...
            반환 데이터 " - 처리 된 결과"; // 반환 처리 결과}, executorService);
    }

    wombetableFuture.allof (futures.toArray (New TompletableFuture [0]). thenRun (() -> {
        목록<string> 결과 = futures.stream ()
                .map (완성성 연관 :: 조인)
                .collect (collectors.tolist ());
        logger.info ( "모든 작업이 완료되었습니다. 결과 : {}", json.tojsonstring (결과));
        // 후속 처리 결과}).
}</string></completablefuture></string>

개선 된 코드는 CompletableFuture.supplyAsync 를 사용하여 각 인터페이스 호출의 결과를 반환하고 futures 목록에 저장됩니다. CompletableFuture.allOf 모든 작업이 완료된 후 결과가 처리되도록합니다. stream().map(CompletableFuture::join).collect(Collectors.toList()) 결과가 원래 순서로 수집되도록하여 결과 순서대로 동시성 문제를 해결합니다. 이 코드는 또한 사용자 정의 스레드 풀을 사용하여 리소스 사용량을보다 잘 제어합니다.

위 내용은 Batch 인터페이스 요청의 순서를 보장하고 결과를 효율적으로 처리하기 위해 완성 가능한 문제를 사용하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!