apache-httpasyncclient - CountDownLatch のカウントがゼロになったときに欠落している HTTP 要求はどこにありますか?

Question

CloseableHttpAsyncClientクライアントを使用して一連の http 要求を送信するマルチスレッド コードをテストしています (以下のコードの抜粋を参照)。

次の出力を取得しています。

 Failed ->java.io.IOException: Connection reset by peer-null
 Failed ->org.apache.http.ConnectionClosedException: Connection closed-null
 Thread: 0-Time: 2955ms-Completed: 1000-Failed: 0-Cancelled: 0- Countdown: 0
 Thread: 1-Time: 2855ms-Completed: 999-Failed: 0-Cancelled: 0-Countdown: 0
 Thread: 2-Time: 2741ms-Completed: 999-Failed: 1-Cancelled: 0-Countdown: 0
 Thread: 3-Time: 2678ms-Completed: 999-Failed: 1-Cancelled: 0-Countdown: 0
 Thread: 4-Time: 2654ms-Completed: 1000-Failed: 0-Cancelled: 0-Countdown: 0

そのため、スレッドのうち 2 つは 1000 件のリクエストすべてを正しく実行し、他の 2 つのスレッドには正しくキャプチャされた接続エラーがあり、スレッドの 1 つ (番号 1) は 999 件のリクエストを完了し、失敗またはキャンセルの通知はありませんでした。

私の質問は次のとおりです。

1. 失敗したメソッドで失敗したリクエストを理解する方法はありますか?

2. すべてのリクエストが完了していないのに、失敗、キャンセル、または例外が発生してカウントダウンの数が 0 にならないのはなぜですか?

   class AsynchThread extends Thread{      
       CloseableHttpAsyncClient httpclient;
       int n;
       int ncompleted =0;
       int nfailed =0;
       int ncancelled =0;
       long time;
       CountDownLatch latch;
   
       public AsynchThread(CloseableHttpAsyncClient httpclient, int n) throws IOReactorException {
           this.jobs = jobs;
           this.httpclient = httpclient;
           this.n = n;
       }
   
       public void process() throws InterruptedException, IOException {
           latch = new CountDownLatch(n);
           long starttime = System.currentTimeMillis();
           for (int v=0;v<n; v++) {
                   HttpPost httppost = ...
                   httpclient.execute(httppost, new FutureCallback<HttpResponse>() {
   
                  public void completed(final HttpResponse response) {
                       latch.countDown();
                       ncompleted += 1;
                   }
   
                   public void failed(final Exception ex) {
                        latch.countDown();
                        nfailed += 1;
                        System.out.println("Failed ->" + ex);
                   }
   
                   public void cancelled() {
                       latch.countDown();
                       ncancelled += 1;
                       System.out.println("Cancelled ->" + ex);
                  }
             });
           }
           latch.await();
           time = System.currentTimeMillis()-starttime;
       }
   
       public void run() {
           try {
               process();
           }catch(Exception e) {
               System.out.println(e.getStackTrace());
           }
       }
   }
   
   public static void main(final String[] args) throws Exception {
       CloseableHttpAsyncClient httpclient = ...
       int n = 5;
       int nprocthread = 1000;
       AsynchThread[] threads = new AsynchThread[n];
       for (int i=0; i<n; i++) {
           threads[i] = acall.createThread(httpclient, nprocthread);
           threads[i].run();
       }
       for(int i = 0; i < threads.length; i++)
            threads[i].join();
       for(int i = 0; i < threads.length; i++) {
           System.out.println("Thread: " + i + "-Time: " + threads[i].time + "ms-Completed: " + 
                           threads[i].ncompleted + "-Failed: " + threads[i].nfailed + "-Cancelled: " + 
                           threads[i].ncancelled + "-Countdown: " + threads[i].latch.getCount());
       }
   }
   

よろしくお願いします。