【转】 Java 指定线程执行顺序(三种方式)

转自:http://blog.csdn.net/difffate/article/details/63684290

方法一:通过共享对象锁加上可见变量来实现。

    public class MyService {  
      
        private volatile int orderNum = 1;  
      
        public synchronized void methodA() {  
            try {  
                while (orderNum != 1) {  
                    wait();  
                }  
                for (int i = 0; i < 2; i++) {  
                    System.out.println("AAAAA");  
                }  
                orderNum = 2;  
                notifyAll();  
            } catch (InterruptedException e) {  
                e.printStackTrace();  
            }  
        }  
      
        public synchronized void methodB() {  
            try {  
                while (orderNum != 2) {  
                    wait();  
                }  
                for (int i = 0; i < 2; i++) {  
                    System.out.println("BBBBB");  
                }  
                orderNum = 3;  
                notifyAll();  
            } catch (InterruptedException e) {  
                e.printStackTrace();  
            }  
        }  
      
        public synchronized void methodC() {  
            try {  
                while (orderNum != 3) {  
                    wait();  
                }  
                for (int i = 0; i < 2; i++) {  
                    System.out.println("CCCCC");  
                }  
                orderNum = 1;  
                notifyAll();  
            } catch (InterruptedException e) {  
                e.printStackTrace();  
            }  
        }  
    }  
import service.MyService;  
public class ThreadAA extends Thread {  
  
    private MyService dbtools;  
  
    public ThreadAA(MyService dbtools) {  
        super();  
        this.dbtools = dbtools;  
    }  
  
    @Override  
    public void run() {  
        dbtools.methodA();  
    }  
  
}  
import service.MyService;  
public class ThreadBB extends Thread {  
  
    private MyService dbtools;  
  
    public ThreadBB(MyService dbtools) {  
        super();  
        this.dbtools = dbtools;  
    }  
  
    @Override  
    public void run() {  
        dbtools.methodB();  
    }  
  
}  
import service.MyService;  
public class ThreadCC extends Thread {  
  
    private MyService dbtools;  
  
    public ThreadCC(MyService dbtools) {  
        this.dbtools = dbtools;  
    }  
  
    @Override  
    public void run() {  
        dbtools.methodC();  
    }  
  
}  
import extthread.ThreadCC;  
import service.MyService;  
import extthread.ThreadAA;  
import extthread.ThreadBB;  
  
public class Run {  
  
    public static void main(String[] args) {  
        MyService myService = new MyService();  
        for (int i = 0; i < 2; i++) {  
            ThreadBB output = new ThreadBB(myService);  
            output.start();  
            ThreadAA input = new ThreadAA(myService);  
            input.start();  
            ThreadCC threadCC = new ThreadCC(myService);  
            threadCC.start();  
        }  
    }  
  
}  

执行结果:

可以看到线程的启动按顺序执行了。共享对象锁,可以保证每个方法只能同时有一个线程进入,配合wait和notifyall方法,可以启动或者唤醒线程。

方法二:通过主线程Join()

class T11 extends Thread {  
    public void run() {  
        System.out.println("in T1");  
    }  
}  
  
class T22 extends Thread {  
    public void run() {  
        System.out.println("in T2");  
    }  
}  
  
class T33 extends Thread {  
    public void run() {  
        System.out.println("in T3");  
    }  
}  
  
public class Test2 {  
    public static void main(String[] args) throws InterruptedException {  
        T11 t1 = new T11();  
        T22 t2 = new T22();  
        T33 t3 = new T33();  
        t1.start();  
        t1.join();  
        t2.start();  
        t2.join();  
        t3.start();  
    }  
}  

方法三:通过线程执行时Join()

class T1 extends Thread {  
    public void run(){  
        Random random = new Random();  
        try {  
            Thread.sleep(random.nextInt(1000));  
        } catch (InterruptedException e) {  
            e.printStackTrace();  
        }  
        System.out.println("in T1");  
    }  
}  
  
class T2 extends Thread{  
    private Thread thread;  
    public T2(Thread thread) {  
        this.thread = thread;  
    }  
  
    public void run(){  
        try {  
            thread.join();  
        } catch (InterruptedException e) {  
            e.printStackTrace();  
        }  
        System.out.println("in T2");  
    }  
}  
  
class T3 extends Thread{  
    private Thread thread;  
    public T3(Thread thread) {  
        this.thread = thread;  
    }  
  
    public void run(){  
        try {  
            thread.join();  
        } catch (InterruptedException e) {  
            e.printStackTrace();  
        }  
        System.out.println("in T3");  
    }  
}  
  
public class Test {  
    public static void main(String[] args) throws InterruptedException {  
        T1 t1 = new T1();  
        T2 t2 = new T2(t1);  
        T3 t3 = new T3(t2);  
        t2.start();  
        t1.start();  
        t3.start();  
    }  
}  
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 该文章转自:http://blog.csdn.net/evankaka/article/details/44153...
    加来依蓝阅读 7,381评论 3 87
  • Java多线程学习 [-] 一扩展javalangThread类 二实现javalangRunnable接口 三T...
    影驰阅读 2,994评论 1 18
  • 本文主要讲了java中多线程的使用方法、线程同步、线程数据传递、线程状态及相应的一些线程函数用法、概述等。 首先讲...
    李欣阳阅读 2,503评论 1 15
  • 写在前面的话: 这篇博客是我从这里“转载”的,为什么转载两个字加“”呢?因为这绝不是简单的复制粘贴,我花了五六个小...
    SmartSean阅读 4,793评论 12 45
  • 编程能力是一种解决问题的能力。如果问题没能被很好地解决,知道再多也没用。 编程能力是一种运用机器解决问题的能力。首...
    切切歆语阅读 431评论 0 0