首页 > 代码库 > java-Lock篇
java-Lock篇
1.Lock
Lock是java.util.concurrent.locks包下的接口，Lock 实现提供了比使用synchronized 方法和语句可获得
的更广泛的锁定操作，它能以更优雅的方式处理线程同步问题。
实现类有：ReentrantLock, ReentrantReadWriteLock.ReadLock,ReentrantReadWriteLock.WriteLock
注意：用sychronized修饰的方法或者语句块在代码执行完之后锁自动释放，而用Lock需要我们手动释放锁，
所以为了保证锁最终被释放(发生异常情况)，要把互斥区放在try内，释放锁放在finally内。
//LockDemo的基本使用,//Lock接口下有ReentrantLock，ReentrantReadWriteLock (读写锁)//使用演示/* Lock l=...; l.lock();//开始锁住 try{ ...//此处为同步块 } finally{ l.unlock();//解锁不像synchronized可以自动释放锁，lock必须手动解锁 }*/import java.util.concurrent.locks.ReentrantLock;public class LockDemo{ public static void main (String []args) { OutPuter op=new OutPuter(); new Thread(op).start(); new Thread(op).start(); new Thread(op).start(); }} class OutPuter implements Runnable{ private ReentrantLock l=new ReentrantLock(); public void run() { l.lock(); try{ for(int i=0;i<3;i++) { System.out.println(Thread.currentThread().getName()+"i="+i); } } finally{ l.unlock(); } }}
2.ReadWriteLock
我们会有一种需求，在对数据进行读写的时候，为了保证数据的一致性和完整性，需要读和写是互斥的，写和写
是互斥的，但是读和读是不需要互斥的，这样读和读不互斥性能更高些，来看一下不考虑互斥情况的代码原型：
public class ReadWriteLockTest { public static void main(String[] args) { final Data data = http://www.mamicode.com/new Data(); for (int i = 0; i < 3; i++) { new Thread(new Runnable() { public void run() { for (int j = 0; j < 5; j++) { data.set(new Random().nextInt(30)); } } }).start(); } for (int i = 0; i < 3; i++) { new Thread(new Runnable() { public void run() { for (int j = 0; j < 5; j++) { data.get(); } } }).start(); } } } class Data { private int data;// 共享数据 public void set(int data) { System.out.println(Thread.currentThread().getName() + "准备写入数据"); try { Thread.sleep(20); } catch (InterruptedException e) { e.printStackTrace(); } this.data =http://www.mamicode.com/ data; System.out.println(Thread.currentThread().getName() + "写入" + this.data); } public void get() { System.out.println(Thread.currentThread().getName() + "准备读取数据"); try { Thread.sleep(20); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + "读取" + this.data); } }
输出结果：
Thread-1准备写入数据 Thread-3准备读取数据 Thread-2准备写入数据 Thread-0准备写入数据 Thread-4准备读取数据 Thread-5准备读取数据 Thread-2写入12 Thread-4读取12 Thread-5读取5 Thread-1写入12
我们要实现写入和写入互斥，读取和写入互斥，读取和读取互斥，在set和get方法加入sychronized修饰符：
public synchronized void set(int data) {...} public synchronized void get() {...}
输出结果：
Thread-0准备写入数据 Thread-0写入9 Thread-5准备读取数据 Thread-5读取9 Thread-5准备读取数据 Thread-5读取9 Thread-5准备读取数据 Thread-5读取9 Thread-5准备读取数据 Thread-5读取9
我们发现，虽然写入和写入互斥了，读取和写入也互斥了，但是读取和读取之间也互斥了，不能并发执行，效率较
低，用读写锁实现代码如下：
class Data { private int data;// 共享数据 private ReadWriteLock rwl = new ReentrantReadWriteLock(); public void set(int data) { rwl.writeLock().lock();// 取到写锁 try { System.out.println(Thread.currentThread().getName() + "准备写入数据"); try { Thread.sleep(20); } catch (InterruptedException e) { e.printStackTrace(); } this.data =http://www.mamicode.com/ data; System.out.println(Thread.currentThread().getName() + "写入" + this.data); } finally { rwl.writeLock().unlock();// 释放写锁 } } public void get() { rwl.readLock().lock();// 取到读锁 try { System.out.println(Thread.currentThread().getName() + "准备读取数据"); try { Thread.sleep(20); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + "读取" + this.data); } finally { rwl.readLock().unlock();// 释放读锁 } } }
输出结果：
Thread-4准备读取数据 Thread-3准备读取数据 Thread-5准备读取数据 Thread-5读取18 Thread-4读取18 Thread-3读取18 Thread-2准备写入数据 Thread-2写入6 Thread-2准备写入数据 Thread-2写入10 Thread-1准备写入数据 Thread-1写入22 Thread-5准备读取数据
java-Lock篇
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。