java创建n个线程，并保证线程同时启动

川长思鸟来 2022-11-17 05:30 250阅读 0赞

问题描述：给你n个赛车，让他们都在起跑线上就绪后，同时出发。

解决方案：用一个for循环创建线程对象，同时调用wait()方法，让所有线程等待；直到最后一个线程页准备就绪后，调用notifyAll()，同时启动所有线程。

思路：思路是，来一辆赛车就加上一把锁，并修改对应的操作数，如果没有全 部就绪就等待，并释放锁，直到最后一辆赛车到场后唤醒所有的赛车线程。

代码：

/**
     * n辆赛车，让他们都在起跑线上就绪后，同时出发
     */
    public class CarCompetion {
        // 参赛赛车的数量
        protected final int totalCarNum = 10;
        // 当前在起跑线的赛车数量
        protected int nowCarNum = 0;
    }

import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    public class Car implements Runnable{
    
        private int carNum;
        private CarCompetion carCompetion = null;
    
        public Car(int carNum, CarCompetion carCompetion) {
            this.carNum = carNum;
            this.carCompetion = carCompetion;
        }
    
        /**
         * 来一辆赛车就加上一把锁，并修改对应的操作数，如果没有全部就绪就等待，并释放锁
         * 直到最后一辆赛车到场后唤醒所有的赛车线程
         */
        @Override
        public void run() {
            synchronized (carCompetion) {
                carCompetion.nowCarNum++;
                while (carCompetion.nowCarNum<carCompetion.totalCarNum) {
                    try {
                        carCompetion.wait();
                    }catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                carCompetion.notifyAll();
            }
            startCar();
        }
    
        private void startCar() {
            System.out.println("Car  num " + this.carNum + " start to run.");
            try {
                Thread.sleep(3000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("Car num " + this.carNum + " get to the finish line.");
        }
    
        public static void main(String[] args) {
            CarCompetion carCompetion = new CarCompetion();
            /**
             * 在Executor框架下，利用Executors的静态方法可以创建三种类型的常用线程池
             * FixedThreadPool这个线程池可以创建固定线程数的线程池
             */
            final ExecutorService carPool = Executors.newFixedThreadPool(carCompetion.totalCarNum);
            for (int i=0;i<carCompetion.totalCarNum;i++) {
                carPool.execute(new Car(i, carCompetion));
            }
        }
    }