美文网首页
Java 线程同步

Java 线程同步

作者: svmachine | 来源:发表于2017-03-03 01:05 被阅读0次

        最近在项目中遇到需要开启多个线程运行不同的功能,同时当线程全部执行完后才能执行主线程的情况,在查找一些资料后有了相应的解决方法,同时还有一些特殊情况需特殊处理,现将处理过程记录如下:
        对于这种线程问题大致可以使用CountDownLatch,jion,FutureTask,static变量,CyclicBarrier五中方法实现:
    1.static变量
        定义一个静态变量,每当一个线程执行完后,static变量减一,当static变量的值为1是执行主线程,不过此时需要对static变量进行同步操作。(这种方法最简单,但并不好)

    
     public class StaticThread implements Runnable{
     public static int flag = 5;
     public static void  main(String[] args) {
         Thread threads[] = new Thread[5];
    
         for(Thread thread : threads) {
             thread = new Thread(new StaticThread());
             thread.start();
         }
    
         while(flag > 0) {
             continue;
         }
         System.out.println("----- 所有线程执行完毕");
     }
    
     @Override
     public void run() {
         System.out.println("当前线程:" + Thread.currentThread().getName() + "启动");
         try {
             Thread.sleep(1000);
         } catch (InterruptedException e) {
             e.printStackTrace();
         }
         System.out.println("当前线程:" + Thread.currentThread().getName() + "结束");
    
         synchronized ((Object)flag) {
             flag-=1;
         }
     }
    }
    结果:
    当前线程:Thread-0启动
    当前线程:Thread-1启动
    当前线程:Thread-2启动
    当前线程:Thread-0结束
    当前线程:Thread-3启动
    当前线程:Thread-1结束
    当前线程:Thread-4启动
    当前线程:Thread-2结束
    当前线程:Thread-3结束
    当前线程:Thread-4结束
    ----- 所有线程执行完毕
    

    2.CountDownLatch
        CountDownLatch类能够实现让一个线程等待其他线程执行完毕再执行,主要是通过一个计数器来完成,初始值为线程数,当线程执行完毕后计数器减一, 直到计数器为0表示线程全部执行完成。

    public class CountDownLatchThread implements Runnable {
        //当前计数器的值
        public static CountDownLatch lock = new CountDownLatch(5);
    
        public static void  main(String[] args) {
            Thread threads[] = new Thread[5];
    
            for(Thread thread : threads) {
                thread = new Thread(new CountDownLatchThread());
                thread.start();
            }
    
            try {
                //等待直至计数器为0
                lock.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
    
            System.out.println("----- 所有线程执行完毕");
        }
    
        @Override
        public void run() {
            System.out.println("当前线程:" + Thread.currentThread().getName() + "启动");
           try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("当前线程:" + Thread.currentThread().getName() + "结束");
    
            //线程执行完毕,调用计数器countDown()方法减1
            lock.countDown();
    
        }
    }
    结果:
    当前线程:Thread-4启动
    当前线程:Thread-4结束
    当前线程:Thread-2启动
    当前线程:Thread-2结束
    当前线程:Thread-1启动
    当前线程:Thread-1结束
    当前线程:Thread-3启动
    当前线程:Thread-3结束
    当前线程:Thread-0启动
    当前线程:Thread-0结束
    ----- 所有线程执行完毕
    

    实际项目遇到的问题:

    一旦run()方法中的实现在lock.countDown()方法前调用了return方法,程序将不会向下执行,不得不在return之前再次调用lock.countDown()方法。(和staitc相似)

    3.join
        join方法是等待该线程死亡。
        每个线程都跳用join方法即可。

    比较麻烦,同时调用的地方需要注意,否则可能会出现依次执行的情况。

    4.FutureTask

    5.CyclicBarrier

    相关文章

      网友评论

          本文标题:Java 线程同步

          本文链接:https://www.haomeiwen.com/subject/jitlgttx.html