Java多线程按指定顺序同步执行

Java多线程按指定顺序同步执行 Java多线程按指定顺序同步执行是Java编程中的一种常见问题，即如何让多个线程按照既定的顺序依次执行。下面将介绍三种解决方案，分别使用newSingleThreadExecutor、join方法和ThreadPoolExecutor。 方法1：使用newSingleThreadExecutor 使用newSingleThreadExecutor可以返回一个仅包含一个线程的线程池，将多个任务交给此Executor时，这个线程池处理完一个任务后接着处理下一个任务，这样就保证了执行顺序，先提交先执行。如果当前线程意外终止，会创建一个新线程继续执行任务。 示例代码如下： ```java ExecutorService pool = Executors.newSingleThreadExecutor(); for(int i=0;i<1000;++i) { final int number = i; pool.execute(()-> { System.out.println("I am " + number); } ); } pool.shutdown(); ``` 方法2：使用join方法 join方法可以使得某个线程A调用join，其他线程就要乖乖等A执行完毕才能执行。示例代码如下： ```java public class Worker implements Runnable { private int number; public Worker(int i) { number = i; } @Override public synchronized void run() { System.out.println("I am " + number); } } public class TestWorker { public static void main(String[] args) { for(int j=0;j<1000;++j) { Thread thread = new Thread(new Worker(j)); thread.start(); try { thread.join(); } catch (InterruptedException e) { e.printStackTrace(); } } } } ``` 方法3：使用ThreadPoolExecutor ThreadPoolExecutor可以设置核心线程数为1，使得线程池只包含一个线程，从而保证执行顺序。示例代码如下： ```java ThreadPoolExecutor pool = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>()); for(int i=0;i<1000;++i) { final int number = i; pool.execute(()-> { System.out.println("I am " + number); }); } pool.shutdown(); ``` ThreadPoolExecutor的构造函数如下： ```java public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler) ``` 参数含义如下： * corePoolSize：核心线程数，建议和cpu的核心数一样。当有任务提交，检测当前线程池内的线程数小于corePoolSize的话，新建线程执行任务，直到达到corePoolSize。 * maximumPoolSize：允许线程池内最大线程数，当队列满了之后，如果线程池内的线程数小于maximumPoolSize新建线程，如果大于等于执行拒绝策略。 * keepAliveTime：线程最大空闲时间，如果设置60s，那么线程空闲60s后自动结束。 Java多线程按指定顺序同步执行可以使用newSingleThreadExecutor、join方法和ThreadPoolExecutor三种方法来实现。