- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for Futures (0.02 sec)
-
fess-crawler/src/test/java/org/codelibs/fess/crawler/interval/impl/HostIntervalControllerTest.java
// Callableタスク(複数)を実行する final ExecutorService executor = Executors.newFixedThreadPool(numTasks); try { final List<Future<Integer>> futures = executor.invokeAll(tasks); for (final Future<Integer> future : futures) { future.get(); } } catch (final InterruptedException e) { // no thing to do } catch (final ExecutionException e) {Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Mar 15 06:52:00 UTC 2025 - 3.2K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/http/HcHttpClientTest.java
// return responseData; // } // } // return null; // } // }); // } // List<Future<ResponseData>> futureList = executorService.invokeAll(list); // for (Future<ResponseData> future : futureList) { // ResponseData responseData = future.get(); // if (responseData != null) { // System.out.println("status: " // + responseData.getHttpStatusCode()Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Sep 06 04:15:37 UTC 2025 - 11.7K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
@Override public AdminClient admin() { return client.admin(); } /** * Executes an index request. * * @param request The index request. * @return Future for the index response. */ @Override public ActionFuture<IndexResponse> index(final IndexRequest request) { return client.index(request); } /**Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Aug 31 05:32:52 UTC 2025 - 25.3K bytes - Viewed (0)