`

最简单高效的tryLock

 
阅读更多

Java代码  收藏代码
  1. import java.util.concurrent.atomic.AtomicBoolean;  
  2.   
  3. /** 
  4.  * @author asme2u 
  5.  */  
  6. public class Lock {  
  7.   
  8.     private AtomicBoolean lock = new AtomicBoolean(true);  
  9.   
  10.     public boolean tryLock() {  
  11.         return lock.compareAndSet(truefalse);  
  12.     }  
  13.   
  14.     public void unlock() {  
  15.         lock.set(true);  
  16.     }  
  17.   
  18. }  

 

原理:CAS

 

优点:

     速度快,约是ReentrantLock的2-3倍

 

 缺点:

     需JDK5.0+

     无条件对象且不可重入

     未获取锁时直接调用unlock不抛IllegalMonitorStateException所以代码必须严格保证获取锁后才能调用unlock

 

适用场景:

    不需要条件对象且当ReentrantLock的tryLock影响了你的性能的时候

 

我的应用场景:

    最近项目中通信程序中的客户端的socket长连接的连接池,客户端使用连接具有高并发但占用连接时间非常短的特点,使用这个类代替ReentrantLock,性能提高了3倍左右。

 

Java代码  收藏代码
  1. import java.util.concurrent.locks.ReentrantLock;  
  2.   
  3. /** 
  4.  * @author asme2u 
  5.  */  
  6. public class TestLock {  
  7.       
  8.     private static long c = 0;  
  9.     public static void main(String[] args) {  
  10.         final Lock l = new Lock();  
  11. //      final ReentrantLock l = new ReentrantLock();  
  12.         Thread t1 = new Thread() {  
  13.             public void run() {  
  14.                 for (int i = 0; i < 100000000;) {  
  15.                     if (l.tryLock()) {  
  16.                         c++;  
  17.                         i++;  
  18.                         l.unlock();  
  19.                     }  
  20.                 }  
  21.             }  
  22.         };  
  23.         Thread t2 = new Thread() {  
  24.             public void run() {  
  25.                 for (int i = 0; i < 100000000;) {  
  26.                     if (l.tryLock()) {  
  27.                         c++;  
  28.                         i++;  
  29.                         l.unlock();  
  30.                     }  
  31.                 }  
  32.             }  
  33.         };  
  34.         long t = System.currentTimeMillis();  
  35.         Thread t3 = new Thread() {  
  36.             public void run() {  
  37.                 for (int i = 0; i < 100000000;) {  
  38.                     if (l.tryLock()) {  
  39.                         c++;  
  40.                         i++;  
  41.                         l.unlock();  
  42.                     }  
  43.                 }  
  44.             }  
  45.         };  
  46.         t1.start();  
  47.         t2.start();  
  48.         t3.start();  
  49.         try {  
  50.             t1.join();  
  51.             t2.join();  
  52.             t3.join();  
  53.         } catch (InterruptedException e) {  
  54.         }  
  55.         System.out.println(c);  
  56.         System.out.println(System.currentTimeMillis() - t);  
  57.     }  
  58. }  

分享到:
评论

相关推荐

    java的lock和synchronized的区别.docx

    tryLock() 仅在调用时锁为空闲状态才获取该锁。如果锁可用,则获取锁,并立即返回值 true。如果锁不可用,则此方法将立即返回值 false。 lock 和 synchronized 都是锁的意思,但是它们有不同的实现机制和应用场景。...

    分布式锁与信号量教程.docx

    public static boolean tryLock(String lockKey, int expireSeconds) { Jedis jedis = new Jedis("localhost", 6379); String result = jedis.set(lockKey, "locked", "NX", "EX", expireSeconds); jedis.close...

    JDK 5.0 中更灵活、更具可伸缩性的锁定机制1

    2. **定时等待**:通过`tryLock(long timeout, TimeUnit unit)`方法,线程可以设定一个等待时间去尝试获取锁,如果超时仍未获取到,线程将返回而不是继续等待。 3. **锁投票**:`ReentrantLock`的`tryLock()`方法...

    Java concurrency之互斥锁_动力节点Java学院整理

    这与`synchronized`块类似,但`ReentrantLock`提供了更细粒度的控制,如尝试非阻塞获取锁(`tryLock()`)、可中断的锁获取(`lockInterruptibly()`)以及对锁状态的查询方法。 总结来说,`ReentrantLock`是Java并发编程...

    java多线程死锁预防机制研究

    if (lock.tryLock(1000, TimeUnit.MILLISECONDS)) { // 尝试获取锁,超时时间为1秒 try { // 执行关键代码段 } finally { lock.unlock(); // 释放锁 } } else { System.out.println("Lock acquisition timed...

    java简单程序小例子

    Java是一种广泛使用的面向对象的编程语言,以其跨平台性、高效性和安全性著称。"Java简单程序小例子"是学习Java编程的初级阶段常见的实践项目,通常包含一系列基础的代码示例,帮助初学者理解语言的基本语法和常用...

    Linux内核同步操作详解

    例如,`down_trylock()`和`up_read_trylock()`这样的宏可以帮助开发者在某些情况下避免等待锁。 #### 八、结语 《Linux内核同步操作详解》为开发者提供了丰富的理论知识和技术细节,帮助他们在开发驱动程序或其他...

    java并发编程学习思维导图

    - **Lock锁**:ReentrantLock是可重入锁,提供了比synchronized更细粒度的控制,如tryLock()、unlock()等。 3. **并发工具类** - **CountDownLatch**:用于计数,常用于多线程协同工作,当计数器归零时,所有等待...

    C#版本简单线程调用源码

    其中,`lock`是最常用的一种,用于控制对共享资源的访问。 4. **线程池** 线程池是一种线程复用机制,它可以避免频繁创建和销毁线程的开销。C#的线程池由`ThreadPool`类提供。你可以通过`ThreadPool....

    ThreadLocked多线程共享资源

    `lock`是C#中实现互斥访问的最简单方式。它基于`Monitor`类,确保同一时刻只有一个线程可以执行锁定的代码块: ```csharp object obj = new object(); lock (obj) { // 共享资源的代码 } ``` 这里,`obj`作为锁...

    【BAT必备】并发编程锁面试题

    - **synchronized关键字**:这是最简单的锁实现方式,可以应用于方法或者代码块。 - **ReentrantLock类**:这是一个可重入的互斥锁,比synchronized更灵活,提供了一系列高级功能。 - **ReentrantReadWriteLock类**...

    关于Linux多线程编程.pdf

    pthread_mutex_trylock用于尝试加锁,而不会阻塞。 2. 条件变量:条件变量是与互斥锁联合使用的同步机制,用于线程间的协调。条件变量允许线程因为某个条件未满足而处于阻塞状态,直到其他线程改变了这个条件并发送...

    一个简单的线程同步实例

    首先,我们来看最基本的同步机制——synchronized关键字。synchronized可以用于方法或者代码块,当它包裹的代码被执行时,会创建一个监视器锁,只有一个线程能获取这个锁并执行代码,其他线程必须等待锁的释放。例如...

    自定义消息的简单实现(c++)

    这个简单的实现展示了如何在C++中创建自定义消息系统,包括定义消息结构、存储消息、发送和接收消息以及处理消息的逻辑。通过这种方式,你可以根据项目需求定制自己的通信协议,以实现更高效、更灵活的程序设计。...

    多线程面试专题及答案.pdf

    - **解答**: 要实现线程之间的执行顺序,最简单的方法是使用`join()`方法。例如: ```java Thread t1 = new Thread(() -&gt; { // T1 的任务 }); Thread t2 = new Thread(() -&gt; { // T2 的任务 }); Thread t3 =...

    【并发编程】简单化理解AQS和ReentrantLock.pdf

    - 可以通过tryLock尝试获取锁,增加灵活性。 - 提供更精细的锁释放控制,避免异常导致的死锁。 #### 5. 认识AQS - **AQS内部实现**: - 通过`state`字段记录锁的状态,使用CAS操作进行原子更新。 - 通过FIFO...

    java多线程实现生产者和消费者

    通常,使用阻塞队列是最简单且高效的解决方案,因为它已经内置了同步和等待机制。然而,在某些特定情况下,如需要更灵活的同步控制或者更高的性能,其他方法可能更合适。理解并熟练掌握这些机制对于进行高并发的Java...

    C# 线程thread 教程

    - `lock`是C#中最简单的同步原语,它基于Monitor对象实现: ```csharp lock (obj) { // 访问共享资源的代码 } ``` 5. **线程池** - .NET框架中的线程池(ThreadPool)是一种高效的线程管理机制,它可以重用...

    Java多线程 简单例子

    除了基本的线程创建和控制,Java还提供了丰富的同步机制,如`synchronized`关键字、`wait()`, `notify()`, `notifyAll()`方法,以及`Lock`接口(如`ReentrantLock`)和`Condition`接口,以支持更复杂的并发控制。...

Global site tag (gtag.js) - Google Analytics