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实现并发控制。
感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!