Java 多线程有序执行的几种方法总结
Java多线程有序执行的几种方法总结
同事无意间提出了这个问题,亲自实践了两种方法。当然肯定还会有更多更好的方法。
方法一
importjava.util.concurrent.atomic.AtomicInteger;
publicclassOrderedThread1{
staticAtomicIntegercount=newAtomicInteger(0);
publicstaticvoidmain(String[]args)throwsInterruptedException{
Tasktask1=newTask(count,0);
Tasktask2=newTask(count,1);
Tasktask3=newTask(count,2);
Threadthread1=newThread(task1);
Threadthread2=newThread(task2);
Threadthread3=newThread(task3);
thread1.setDaemon(true);
thread2.setDaemon(true);
thread3.setDaemon(true);
thread1.start();
thread2.start();
thread3.start();
Thread.sleep(1*1000);
}
}
classTaskimplementsRunnable{
privateAtomicIntegercount;
privateintorder;
publicTask(AtomicIntegercount,intorder){
this.count=count;
this.order=order;
}
@Override
publicvoidrun(){
while(true){
if(count.get()%3==order){
System.out.println(Thread.currentThread().getName()+"====="+order);
count.incrementAndGet();
}
}
}
}
这种方法应该是比较常见的解决方案。利用原子递增控制线程准入顺序。
方法二
publicclassOrderedThread2{
staticHolderholder=newHolder();
publicstaticvoidmain(String[]args)throwsInterruptedException{
Task1task1=newTask1(holder,0);
Task1task2=newTask1(holder,1);
Task1task3=newTask1(holder,2);
Threadthread1=newThread(task1);
Threadthread2=newThread(task2);
Threadthread3=newThread(task3);
thread1.setDaemon(true);
thread2.setDaemon(true);
thread3.setDaemon(true);
thread1.start();
thread2.start();
thread3.start();
Thread.sleep(1*1000);
}
}
classTask1implementsRunnable{
Holderholder;
intorder;
publicTask1(Holderholder,intorder){
this.holder=holder;
this.order=order;
}
@Override
publicvoidrun(){
while(true){
if(holder.count%3==order){
System.out.println(Thread.currentThread().getName()+"====="+order);
holder.count++;
}
}
//inti=0;
//while(i++<10000){
//holder.count++;
//}
}
}
classHolder{
volatileintcount=0;
}
方法二使用了volatile关键字。让每个线程都能拿到最新的count的值,当其中一个线程执行++操作后,其他两个线程就会拿到最新的值,并检查是否符合准入条件。
ps:volatile不是线程安全的。而且两者没有任何关系。volatile变量不在用户线程保存副本,因此对所有线程都能提供最新的值。但试想,如果多个线程同时并发更新这个变量,其结果也是显而易见的,最后一次的更新会覆盖前面所有更新,导致线程不安全。在方法二中,一次只有一个线程满足准入条件,因此不存在对变量的并发更新。volatile的值是最新的与线程安全完全是不相干的,所以不要误用volatile实现并发控制。
感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!