JAVA多线程10个线程处理1000个数据

﹏ヽ暗。殇╰゛Y 2022-04-18 00:52 1016阅读 0赞

import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    public class MultiThreadTest {
    
        public static void main(String[] args) throws Exception {
            List<Integer> idList = new ArrayList<>();
            for (int i = 0; i < 1000; i++) {
                idList.add(i);
            }
            int threadNum = 10;
            ExecutorService executorService = Executors.newFixedThreadPool(threadNum);
            CountDownLatch countDownLatch = new CountDownLatch(threadNum);
            int perSize = idList.size() / threadNum;
            for (int i = 0; i < threadNum; i++) {
                MultiThread thread = new MultiThread();
                thread.setIdList(idList.subList(i * perSize, (i + 1) * perSize));
                thread.setCountDownLatch(countDownLatch);
                executorService.submit(thread);
            }
            countDownLatch.await();
            executorService.shutdown();
        }
    }
    
    class MultiThread extends Thread {
        private List<Integer> idList;
    
        private CountDownLatch countDownLatch;
    
        public void setIdList(List<Integer> idList) {
            this.idList = idList;
        }
    
        public void setCountDownLatch(CountDownLatch countDownLatch) {
            this.countDownLatch = countDownLatch;
        }
    
        @Override
        public void run() {
            try {
                Thread.sleep(1000);
                System.out.println(this.idList);
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                if (countDownLatch != null) {
                    countDownLatch.countDown();
                }
            }
        }
    }