通过使用Java提供的线程池,可以将多个请求分配到不同的线程中并行执行。可以通过创建固定数量的线程池,然后将请求分配给线程池来实现。线程池会自动管理线程的数量和复用,从而减少了线程创建和销毁的开销,提高了程序的性能。
以下是使用线程池实现同时进行多个请求的代码示例:
ExecutorService executor = Executors.newFixedThreadPool(10); // 创建一个固定大小的线程池List> tasks = new ArrayList<>();for (int i = 0; i < requestCount; i++) {tasks.add(new RequestTask(i)); // 将请求任务添加到列表中
}List> results = executor.invokeAll(tasks); // 并行执行所有请求executor.shutdown(); // 关闭线程池
Java 8提供了并行流的支持,可以方便地将操作并行化。使用并行流,可以将多个请求转换为流,然后使用parallel()方法将其并行化,从而并行执行多个请求。
以下是使用Java 8的并行流实现同时进行多个请求的代码示例:
List results = requests.parallelStream().map(request -> executeRequest(request)).collect(Collectors.toList());
Java 8中还提供了CompletableFuture类,它提供了非常方便的异步编程方式。使用CompletableFuture,可以将多个请求转换为CompletableFuture对象,然后使用allOf()方法将它们并行化执行。这种方式可以更加灵活地控制请求的执行顺序和异常处理。
以下是使用CompletableFuture实现同时进行多个请求的代码示例
CompletableFuture[] futures = new CompletableFuture[requestCount];for (int i = 0; i < requestCount; i++) {CompletableFuture future = CompletableFuture.supplyAsync(() -> executeRequest(i));futures[i] = future;
}CompletableFuture allFutures = CompletableFuture.allOf(futures); // 并行执行所有请求List results = Arrays.stream(futures).map(CompletableFuture::join).collect(Collectors.toList());
以上是几种常用的Java实现同时进行多个请求并行执行的方式,开发者可以根据具体的业务场景和需求选择适合自己的方式。
这里我使用的是CompletableFuture异步编程方式,循环异步请求数据
需求:将12个时间节点,作为时间参数远程调用接口循环请求12次
//list:12个时间节点for (String time : list) {i++;CompletableFuture futureTask = CompletableFuture.supplyAsync(() -> {WeatherBaseBo weatherBaseBo = new WeatherBaseBo();List objPageData = null;try {BaseRespBo ofLonsAndLats = getOfLonsAndLats(dataCodeGrid, gridElements, time, latitude, longitude);objPageData = ofLonsAndLats.getObjPageData();if (objPageData.size() < 1 && null == objPageData) {String date = weatherUtil.date(time);ofLonsAndLats = getOfLonsAndLats(dataCodeGrid, gridElements, date, latitude, longitude);objPageData = ofLonsAndLats.getObjPageData();}String weather = JSONObject.toJSONString(objPageData.get(0));JSONObject jsonObject = JSONObject.parseObject(weather);String u = jsonObject.getString("10U");String v = jsonObject.getString("10V");String rainc = jsonObject.getString("RAINC"); //1小时累计降水String weatherStr = jsonObject.getString("2T");BigDecimal weather1 = new BigDecimal(weatherStr); //2米温度String zdlat = (String) jsonObject.get("lat"); //站点纬度String zdlon = (String) jsonObject.get("lon"); //站点经度String dateTime = (String) jsonObject.get("data_time");String winPower = weatherUtil.calculationWspdString(Double.valueOf(u), Double.valueOf(v));String windDir = weatherUtil.calculationWdir(Double.valueOf(u), Double.valueOf(v));weatherBaseBo.setRain(rainc);weatherBaseBo.setWindSpeed(winPower);weatherBaseBo.setT(weather1 + "");weatherBaseBo.setLats(zdlat);weatherBaseBo.setLons(zdlon);weatherBaseBo.setTime(dateTime);weatherBaseBo.setWindDir(windDir);
// } catch (Exception e) {log.error("实况折线图平台接口请求报错,请求时间:{}", time);e.printStackTrace();}return weatherBaseBo;});futures[i] = futureTask;}CompletableFuture.allOf(futures);List weatherBaseBos = Arrays.stream(futures).map(CompletableFuture::join).collect(Collectors.toList());
可以实现多个请求异步执行并且同步返回。
上一篇:web前端——HTML+CSS
下一篇:C语言 | 问题20230225