배치 인터페이스 요청 결과의 주문 일관성을 보장하기 위해 완성 가능한 문제를 사용하는 방법은 무엇입니까?

배치 인터페이스 요청의 효율적으로 동시 처리 : 결과 순서가 일관되게 보장

다수의 타사 인터페이스에 대한 동시 호출은 대량의 데이터를 효율적으로 처리 할 때 효율성을 크게 향상시킬 수 있습니다. 그러나 간단한 다중 스레드 동시성으로 인해 반환 결과 순서가 일치하지 않으며 원래 데이터 목록에 해당하지 않을 수 있습니다. 이 기사에서는 Java의 CompletableFuture 문제를 사용 하여이 문제를 해결하는 방법을 소개하여 인터페이스 통화 결과가 원래 데이터 순서와 정확히 동일하도록합니다.

질문:

1000 개 이상의 타사 인터페이스를 동시에 호출하고 결과를 반환하기 위해 처리해야한다고 가정하십시오. 여러 스레드가 루프 for 단순을 사용하여 시작되면 인터페이스 호출 순서를 보장 할 수 없으며 최종 결과 순서는 원래 데이터 목록과 일치하지 않습니다. 일부 샘플 코드는 CompletableFuture.runAsync 사용하여 비동기 작업을 수행하지만 결과 수집과 순차적 유지를 무시합니다.

해결책:

결과 순서가 원래 데이터 목록과 일치하는지 확인하기 위해 Key는 CompletableFuture.supplyAsync 대신 CompletableFuture.runAsync 를 사용하는 것입니다. supplyAsync 메소드는 결과를 반환 할 수 있지만 runAsync 값을 반환하지 않습니다. supplyAsync 통해 각 인터페이스 호출의 결과를 반환 한 다음 스트리밍 처리를 통해 결과를 목록에 수집하여 결과 순서가 원래 데이터 목록과 일치하는지 확인하십시오.

개선 된 코드 :

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

    executorService executorService = new ThreadPooleExecutor (
            // 핵심 스레드 수 런타임 ().
            // 최대 스레드 수 Runtime.getRuntime (). availprocessors () * 2,
            // 스레드 생존 시간 60L, TimeUnit.seconds,
            새로운 LinkedBlockingqueue  (),
            새로운 ThreadPoolexecutor.callerrunspolicy ());

    목록 <completablefuture> > futures = new ArrayList  ();
    (문자열 데이터 : Datalist) {
        futures.add (wempletablefuture.supplyAsync (() -> {
            logger.info ( "비동기 스레드의 실행 시작->> 데이터);
            // 인터페이스를 호출하고 데이터를 전달합니다
            // 인터페이스 반환 값에 따라 데이터 일치 여부를 판단하십시오. // 처리 된 결과 반환 프로세스 데이터 (데이터); // 데이터를 처리하고 결과를 반환}, executorService)); // 사용자 정의 스레드 풀 사용}

    // 완료된 모든 요청의 논리를 처리 한 후, 완료 가능한future.allof (futures.toArray (new waldableFuture [0]). thenRun (() -> {
        목록<string> 결과 = futures.stream ()
                .map (완성성 연관 :: 조인)
                .collect (collectors.tolist ());
        logger.info ( "스레드 실행이 완료되었습니다 : {}", json.tojsonstring (results));
        // SMS를 보내기 위해 호출}).
}

// 데이터 처리 방법, 개인 정적 문자열 프로세스 데이터 (String Data)를 수정합니다.
    // ... 인터페이스 호출 및 데이터 처리 로직 ...
    반환 데이터 "처리 된 결과";
}</string></completablefuture></string>

futures List에 각 CompletableFuture 의 결과를 저장하고 futures.stream().map(CompletableFuture::join).collect(Collectors.toList()) 사용하여 결국 결과를 수집함으로써 결과 순서는 원래 데이터 목록과 일치하도록 보장합니다. CompletableFuture::join 메소드 블록이 CompletableFuture 결과가 얻어 질 때까지 블록 블록합니다. 이것은 원래 코드에서 일치하지 않는 결과의 문제를 효과적으로 해결합니다.

위 내용은 배치 인터페이스 요청 결과의 주문 일관성을 보장하기 위해 완성 가능한 문제를 사용하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!