`

AtomicBoolean运用

阅读更多

 

首先先看如下例子 
Java代码  收藏代码
  1. private static class BarWorker implements Runnable {  
  2.   
  3.  private static boolean exists = false;  
  4.   
  5.  private String name;  
  6.   
  7.  public BarWorker(String name) {  
  8.   this.name = name;  
  9.  }  
  10.   
  11.  public void run() {  
  12.   if (!exists) {  
  13.    exists = true;  
  14.    System.out.println(name + " enter");  
  15.    System.out.println(name + " working");  
  16.    System.out.println(name + " leave");  
  17.    exists = false;  
  18.   } else {  
  19.    System.out.println(name + " give up");  
  20.   }  
  21.  }  
  22.   
  23. }  

static变量exists用来实现同一时间只有一个worker在工作. 但是假设exists的判断和exists = true;之间有了 
其他指令呢 
Java代码  收藏代码
  1. private static class BarWorker implements Runnable {  
  2.   
  3.  private static boolean exists = false;  
  4.   
  5.  private String name;  
  6.   
  7.  public BarWorker(String name) {  
  8.   this.name = name;  
  9.  }  
  10.   
  11.  public void run() {  
  12.   if (!exists) {  
  13.    try {  
  14.     TimeUnit.SECONDS.sleep(1);  
  15.    } catch (InterruptedException e1) {  
  16.     // do nothing  
  17.    }  
  18.    exists = true;  
  19.    System.out.println(name + " enter");  
  20.    try {  
  21.     System.out.println(name + " working");  
  22.     TimeUnit.SECONDS.sleep(2);  
  23.    } catch (InterruptedException e) {  
  24.     // do nothing  
  25.    }  
  26.    System.out.println(name + " leave");  
  27.    exists = false;  
  28.   } else {  
  29.    System.out.println(name + " give up");  
  30.   }  
  31.  }  
  32.   
  33. }  

这时输出是 
bar2 enter 
bar2 working 
bar1 enter 
bar1 working 
bar1 leave 
bar2 leave 
看到两个线程同时工作了. 
这时可以用AtomicBoolean 
Java代码  收藏代码
  1. private static class BarWorker implements Runnable {  
  2.   
  3.   private static AtomicBoolean exists = new AtomicBoolean(false);  
  4.   
  5.   private String name;  
  6.   
  7.   public BarWorker(String name) {  
  8.    this.name = name;  
  9.   }  
  10.   
  11.   public void run() {  
  12.    if (exists.compareAndSet(falsetrue)) {  
  13.     System.out.println(name + " enter");  
  14.     try {  
  15.      System.out.println(name + " working");  
  16.      TimeUnit.SECONDS.sleep(2);  
  17.     } catch (InterruptedException e) {  
  18.      // do nothing  
  19.     }  
  20.     System.out.println(name + " leave");  
  21.     exists.set(false);  
  22.    }else{  
  23.     System.out.println(name + " give up");  
  24.    }  
  25.   }  
  26.   
  27.  }  

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

相关推荐

    JAVA后端架构师.pdf

    他们能够熟练应对常见的并发编程问题,掌握至少一个常见中间件的源码,能够运用设计模式、OOA/D进行软件设计,并在微服务层面掌握常见微服务组件的操作、原理和源码。 技术要点: 1. 操作系统基础知识:微内核与宏...

    tuixiangzi_java_atomicpw4_

    5. **Java并发与原子操作**:“atomicpw4”标签暗示了项目中可能使用了Java并发工具包(java.util.concurrent.atomic)中的原子类,如AtomicInteger或AtomicBoolean,以保证在多线程环境下对游戏状态的更新是线程...

    并发编程的艺术

    6. **原子变量**:Atomic类提供了一组原子操作,如AtomicInteger、AtomicBoolean等,它们在多线程环境下保证更新操作的原子性,无需使用锁。 7. **并发工具类**:如CountDownLatch、CyclicBarrier、Semaphore等,...

    Java多线程之进阶篇(二).docx

    - `AtomicBoolean`:用于原子操作`boolean`类型的变量。 - `AtomicInteger` 和 `AtomicLong`:分别用于原子操作`int`和`long`类型的变量,提供了原子性的增加、减少、设置等操作。 2. **引用原子类**: - `...

    java_util_concurrent_user_guide并发工具包详解

    - `AtomicInteger`, `AtomicLong`, `AtomicBoolean`: 提供了原子性的整型、长型和布尔型变量操作,避免了显式的同步。 - `AtomicReference`: 支持原子性地更新引用的对象。 6. **ThreadLocal** - `ThreadLocal` ...

    java5 并发包 (concurrent)思维导图

    - `AtomicInteger`、`AtomicLong`、`AtomicBoolean`等:提供原子操作的整型、长整型和布尔型变量,无需显式同步即可保证线程安全。 - `AtomicReference`、`AtomicStampedReference`、`AtomicMarkableReference`:...

    juc详解juc详解juc详解juc详解juc详解juc详解juc详解

    - `AtomicInteger`、`AtomicLong`、`AtomicBoolean`等提供了原子操作,保证了在多线程环境下的数据一致性,避免了`synchronized`的使用。 6. **线程中断与中断响应**: - `Thread.interrupt()`用于设置线程的中断...

    JAVA并发编程实践.rar

    10. **原子操作与Atomic类**:Java提供了一组原子类,如AtomicInteger、AtomicBoolean等,它们保证了基本类型的原子性操作,无需使用synchronized进行同步。 11. **并发编程设计模式**:如生产者-消费者模式、读写...

    火山安卓多线程技术源码.rar

    "火山安卓多线程技术源码"提供了一套关于如何在Android平台上运用多线程的实例代码。 1. **线程基础** - **线程概念**:线程是程序执行的最小单元,每个进程可以有多个线程同时执行。 - **主线程**:Android中的...

    针对于Executor框架,Java API,线程共享数据

    - **AtomicBoolean**:用于boolean类型的原子操作。 - **AtomicInteger**:适用于int类型的原子操作。 - **AtomicLong**:用于long类型的原子操作。 - **AtomicReference**:提供对引用类型的原子操作。 - **...

    线程的几种控制方式以及线程间的几种通信方式

    5. **事件(Event)**:Java的`java.util.concurrent.atomic.AtomicBoolean`可以模拟一个简单的事件,Python的`threading.Event`对象则提供了更完善的事件机制。 6. **管道(Pipe)**:在多进程通信中常见,但在...

    java多线程学习笔记

    - **Atomic包**:提供原子操作类,如AtomicInteger、AtomicBoolean等,保证操作的原子性和可见性。 - **CompletableFuture**:用于异步计算,支持链式调用和组合多个异步任务。 在提供的源代码中,可能会涵盖上述...

    java并发编程实践

    在实际开发过程中,合理运用Java并发编程技术,不仅可以提高程序性能,还能简化复杂度。 ##### 5.1 减少锁的竞争 - 使用局部变量代替共享变量。 - 尽量减少锁的粒度,采用细粒度锁。 ##### 5.2 使用并发容器 - `...

    JUC

    - AtomicInteger,AtomicLong,AtomicBoolean等:提供原子操作的整数、长整型和布尔类型变量,避免了显式同步。 - AtomicReference,AtomicIntegerArray等:原子操作引用和其他数组类型,确保多线程环境下的数据...

    原子库:没有人要求的科学怪人图书馆

    此外,AtomicBoolean、AtomicIntegerArray、AtomicLongArray等类提供了对基本类型数组的原子操作,使数组元素的修改也能在并发环境中保持线程安全。 在深入理解Java原子库时,我们还需要了解其背后的底层机制,如...

    uncheck:不再处理异常

    8. **`Unchecked` 工具类**:在Java中,`java.util.concurrent.atomic.AtomicBoolean` 和其他并发工具类提供了 `uncheck` 方法,它允许将一个抛出检查异常的函数包装成不抛出异常的函数。这种方法主要用于简化多线程...

    non-blocking-algorithms-java:Java非阻塞算法

    其中,`Atomic`类(如`AtomicInteger`、`AtomicBoolean`等)提供了原子操作,使得多个线程可以安全地访问共享变量而无需锁定。 1. **原子类与CAS操作**:原子类的实现基于无锁(Lock-Free)或比较并交换(Compare-...

Global site tag (gtag.js) - Google Analytics