Java 线程同步

    最近在项目中遇到需要开启多个线程运行不同的功能,同时当线程全部执行完后才能执行主线程的情况,在查找一些资料后有了相应的解决方法,同时还有一些特殊情况需特殊处理,现将处理过程记录如下:
    对于这种线程问题大致可以使用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

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 正常情况下,每个子线程完成各自的任务就可以结束了。不过有的时候,我们希望多个线程协同工作来完成某个任务,这时就涉及...
    野梦M阅读 3,395评论 0 2
  • 一、多线程 说明下线程的状态 java中的线程一共有 5 种状态。 NEW:这种情况指的是,通过 New 关键字创...
    Java旅行者阅读 10,181评论 0 44
  • 1. 死锁的产生条件 计算机系统中同时具备下面四个必要条件时,那么会发生死锁 互斥条件。即某个资源在一段时间内只能...
    酱油和醋阅读 5,397评论 0 4
  • 一 夫妻 爸妈 儿女 聚合是家 柴米油盐酱醋茶 结合成家 儿女学费 妈妈心牵挂 老妈老爸的身体 药是不是断啦 小张...
    卓君务阅读 2,241评论 0 2
  • 爱情是什么? 这是古今中外最吸引人的一个问题 也是最难回答的一个问题 也许一千个人会有一千种不同的答案 没人能够给...
    酷听听书阅读 2,144评论 0 0