线程执行桉指定顺序执行
方法一:
package cn.itcast.yilai; import java.sql.*; import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; public class ThreadTest { // T1、T2、T3三个线程顺序执行 public static void main(String[] args) { //blockingQueue保证顺序 BlockingQueue<Thread> blockingQueue = new LinkedBlockingQueue<Thread>(); Thread t1 = new Thread(new Work()); Thread t2 = new Thread(new Work()); Thread t3 = new Thread(new Work()); blockingQueue.add(t1); blockingQueue.add(t2); blockingQueue.add(t3); for (int i=0;i<3;i++) { Thread t = null; try { t = blockingQueue.take(); } catch (InterruptedException e) { e.printStackTrace(); } t.start(); //检测线程是否还活着 while (t.isAlive()); } } static class Work implements Runnable { public void run() { System.out.println("thread start:" + Thread.currentThread().getName()); } } }
方法二:
package cn.itcast.yilai; import java.sql.*; import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; public class ThreadTest { // T1、T2、T3三个线程顺序执行 public static void main(String[] args) { //blockingQueue保证顺序 BlockingQueue<Thread> blockingQueue = new LinkedBlockingQueue<Thread>(); Thread t1 = new Thread(new Work()); Thread t2 = new Thread(new Work()); Thread t3 = new Thread(new Work()); blockingQueue.add(t1); blockingQueue.add(t2); blockingQueue.add(t3); for (int i=0;i<3;i++) { Thread t = null; try { t = blockingQueue.take(); } catch (InterruptedException e) { e.printStackTrace(); } t.start(); //检测线程是否还活着 while (t.isAlive()); } } static class Work implements Runnable { public void run() { System.out.println("thread start:" + Thread.currentThread().getName()); } } }