AtomicBoolean运用

首先先看如下例子

 private static class BarWorker implements Runnable {

  private static boolean exists = false;

  private String name;

  public BarWorker(String name) {
   this.name = name;
  }

  public void run() {
   if (!exists) {
    exists = true;
    System.out.println(name + " enter");
    System.out.println(name + " working");
    System.out.println(name + " leave");
    exists = false;
   } else {
    System.out.println(name + " give up");
   }
  }

 }

static变量exists用来实现同一时间只有一个worker在工作. 但是假设exists的判断和exists = true;之间有了
其他指令呢

 private static class BarWorker implements Runnable {

  private static boolean exists = false;

  private String name;

  public BarWorker(String name) {
   this.name = name;
  }

  public void run() {
   if (!exists) {
    try {
     TimeUnit.SECONDS.sleep(1);
    } catch (InterruptedException e1) {
     // do nothing
    }
    exists = true;
    System.out.println(name + " enter");
    try {
     System.out.println(name + " working");
     TimeUnit.SECONDS.sleep(2);
    } catch (InterruptedException e) {
     // do nothing
    }
    System.out.println(name + " leave");
    exists = false;
   } else {
    System.out.println(name + " give up");
   }
  }

 }

这时输出是
bar2 enter
bar2 working
bar1 enter
bar1 working
bar1 leave
bar2 leave
看到两个线程同时工作了.
这时可以用AtomicBoolean

private static class BarWorker implements Runnable {

  private static AtomicBoolean exists = new AtomicBoolean(false);

  private String name;

  public BarWorker(String name) {
   this.name = name;
  }

  public void run() {
   if (exists.compareAndSet(false, true)) {
    System.out.println(name + " enter");
    try {
     System.out.println(name + " working");
     TimeUnit.SECONDS.sleep(2);
    } catch (InterruptedException e) {
     // do nothing
    }
    System.out.println(name + " leave");
    exists.set(false);
   }else{
    System.out.println(name + " give up");
   }
  }

 }

因为它提供了原子性操作,其中exists.compareAndSet(false, true)这个操作把比较和赋值操作组成了一个原子操作,
中间不会提供可乘之机.输出为
bar1 enter
bar1 working
bar2 give up

评论

5 楼 kabike 2015-08-28  

QQ1289714862 写道

这代码有问题吧 bar1 bar2 那来的 你是不是new了两个Runnable

应该是,太久了已经忘了

4 楼 QQ1289714862 2015-08-26  

这代码有问题吧 bar1 bar2 那来的 你是不是new了两个Runnable

3 楼 kabike 2013-09-24  

annybz 写道

我还想再问一共 问题，

private static class BarWorker implements Runnable { 
 
  private static AtomicBoolean exists = new AtomicBoolean(false); 
 
  private String name; 
 
  public BarWorker(String name) { 
   this.name = name; 
  } 
 
  public void run() { 
   if (exists.compareAndSet(false, true)) { 
    System.out.println(name + " enter"); 
    try { 
     System.out.println(name + " working"); 
     TimeUnit.SECONDS.sleep(2); 
    } catch (InterruptedException e) { 
     // do nothing 
    } 
    System.out.println(name + " leave"); 
    exists.set(false); 
   }else{ 
    System.out.println(name + " give up"); 
   } 
  } 
 
}
会不会第一个线程进入了if的方法，然后执行到 exists.set(false)之后，第二个线程才进入，这个时候不就可以是两个线程运行了吗，可是我执行了很多遍，发现始终只有一个线程在运行，您能给我解释下吗?谢谢

这个本来也没能防止两个线程同时运行,只是防止它俩同时进入临界区.exists.set(false)时,线程离开了临界区

2 楼 annybz 2013-09-22  

我还想再问一共 问题，

private static class BarWorker implements Runnable { 
 
  private static AtomicBoolean exists = new AtomicBoolean(false); 
 
  private String name; 
 
  public BarWorker(String name) { 
   this.name = name; 
  } 
 
  public void run() { 
   if (exists.compareAndSet(false, true)) { 
    System.out.println(name + " enter"); 
    try { 
     System.out.println(name + " working"); 
     TimeUnit.SECONDS.sleep(2); 
    } catch (InterruptedException e) { 
     // do nothing 
    } 
    System.out.println(name + " leave"); 
    exists.set(false); 
   }else{ 
    System.out.println(name + " give up"); 
   } 
  } 
 
}
会不会第一个线程进入了if的方法，然后执行到 exists.set(false)之后，第二个线程才进入，这个时候不就可以是两个线程运行了吗，可是我执行了很多遍，发现始终只有一个线程在运行，您能给我解释下吗?谢谢

1 楼 annybz 2013-09-22  

我试了第一个用exists控制只有一个线程运行的，结果是可能会看到一个线程运行，也可能看到2个线程运行的。


public class BarWorker implements Runnable {

private static Boolean exists = false;
private String name;

public BarWorker(String name) {
this.name = name;
}

@Override
public void run() {
System.out.println(name + "---"+exists);
if (!exists) {
exists = true;
System.out.println(name + "enter");
System.out.println(name + "working");
System.out.println(name + "leaving");
exists = false;

} else {
System.out.println(name + "give up");
}

}

public static void main(String[] args) {
BarWorker work1 = new BarWorker("bar1");
BarWorker work2 = new BarWorker("bar2");

Thread t1 = new Thread(work1);
Thread t2 = new Thread(work2);

t1.start();
t2.start();
}

}