码迷,mamicode.com
首页 > 编程语言 > 详细

leetCode例题引出的多线程CountDownLatch和CyclicBarrier使用例题

时间:2019-11-22 19:02:30      阅读:90      评论:0      收藏:0      [点我收藏+]

标签:err   catch   一个   barrier   并且   throws   class   countdown   nbsp   

先介绍下CountDownLatch和CyclicBarrier;

CountDownLatchnew CountDownLatch(n),初始化时会赋值,并且不可以重新赋值。

                              countDown(),值减1,操作,当值为0时,会跳过所有的阻塞方法await();

                              await(),阻塞方法,一直阻塞到值为0;

CyclicBarrier:new CyclicBarrier(m),m代表着,每次阻拦的阈值,当阻拦的await方法的个数等于m时,所有的阻塞方法则会跳过。然后开始阻塞下一批线程,每批数量为m。

                        await(),阻塞方法,每次阻塞的格式为m。

 

题目1115:

我们提供一个类:

class FooBar {
  public void foo() {
    for (int i = 0; i < n; i++) {
      print("foo");
    }
  }

  public void bar() {
    for (int i = 0; i < n; i++) {
      print("bar");
    }
  }
}

两个不同的线程将会共用一个 FooBar 实例。其中一个线程将会调用 foo() 方法,另一个线程将会调用 bar() 方法。
请设计修改程序,以确保 "foobar" 被输出 n 次。

线上最受赞答案:

 1 import java.util.concurrent.CountDownLatch;
 2 import java.util.concurrent.CyclicBarrier;
 3 
 4 public class FooBar{
 5       private int n;
 6       private CountDownLatch countDownLatch;  //countDownLatch只能复制一次,在值为0时,await()才会执行完毕
 7       private CyclicBarrier cyclicBarrier;    //cyclicBarrier可以复制多次,值为每组多少个成员。
 8 
 9       public FooBar(int n){
10           this.n=n;
11           countDownLatch = new CountDownLatch(1);   
12           cyclicBarrier = new CyclicBarrier(2);   //每组两个成员
13       }
14 
15       public void foo(Runnable printFoo) throws InterruptedException {
16           try{
17               for (int i=0;i<n;i++){
18                   printFoo.run();     //打印foo
19                   countDownLatch.countDown();  //打印完后,其中值变为0,28行阻塞开始跳过,打印bar
20                   cyclicBarrier.await();    //阻塞,等阻塞的线程为2时,跳过改方法
21               }
22           } catch (Exception e){}
23       }
24 
25     public void bar(Runnable printBar) throws InterruptedException {
26         try{
27             for (int i=0;i<n;i++){
28                 countDownLatch.await();  //阻塞,确保先打印foo
29                 printBar.run();    //打印bar
30                 countDownLatch = new CountDownLatch(1);  //为打印下一组foobar做准备
31                 cyclicBarrier.await();  //阻塞,等阻塞的线程为2时,跳过改方法
32             }
33         } catch (Exception e){}
34     }
35 
36 }

 

leetCode例题引出的多线程CountDownLatch和CyclicBarrier使用例题

标签:err   catch   一个   barrier   并且   throws   class   countdown   nbsp   

原文地址:https://www.cnblogs.com/parent-absent-son/p/11913285.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!