概要

java 并發 簡單使用

代碼

    public static final ExecutorService EXECUTOR_GENERAL = new ThreadPoolExecutor(100, 1000,0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(10000));

        int size = 1000;List<UserService> userServices = new ArrayList<>(size);List<CarService> carServices = new ArrayList<>(size);CountDownLatch countDownLatch = new CountDownLatch(1000);for (int i = 0; i < size; i++) {EXECUTOR_GENERAL.execute(() -> {try {System.out.println("cur thread " + Thread.currentThread().getName());UserService userService = applicationContext.getBean(UserService.class);userServices.add(userService);CarService carService = applicationContext.getBean(CarService.class);carServices.add(carService);} catch (Exception ignore) {} finally {countDownLatch.countDown();}});}boolean await = countDownLatch.await(5, TimeUnit.SECONDS);