线程池代码与测试

@Slf4j
@SpringBootTest(classes = ReportApplication.class)
@RunWith(SpringRunner.class)
public class NewTest {

//
//    private static ExecutorService executor = new ThreadPoolExecutor(10, 30,
//            60L, TimeUnit.SECONDS, new ArrayBlockingQueue(10));
    private ScheduledExecutorService executor = Executors.newScheduledThreadPool(2);
    

    @Test
    public void test2()  {

        //执行具体业务
        List<Long> idList = new LinkedList<>();
        for (int i = 0; i < 10; i++) {
            idList.add(Long.valueOf(i));
        }
        for (Long i : idList) {
            System.out.println(i);
            try {
                //执行业务模拟===========
                executor.execute(new Runnable() {
                    @Override
                    public void run() {
                        System.out.println("name:" + Thread.currentThread().getName());
                        System.out.println("thredId:" + Thread.currentThread().getId());
                        Date start = new Date();
                        try {
                            Thread.sleep(5000);
                        } catch (InterruptedException e) {
                            log.error("e:", e);
                        }
                        Date end = new Date();
                        log.info("start:{},end:{}", start, end);
                        System.out.println("start:" + start + "   end:" + end);
                    }
                });
            } catch (Exception e) {
                log.error("threadPool e:", e);
            }
        }

    }

}

result

0
1
2
3
4
5
6
7
8
9
name:pool-1-thread-1
thredId:111
name:pool-1-thread-2
thredId:112