Java 中的锁如何使用？有什么注意事项？
发布时间：2020-12-15 07:23:15 所属栏目：Java 来源：网络整理
导读：Java 中常见的锁有 synchronized 可重入锁 java.util.concurrent.lock.ReentrantLock 可重复读写锁 java.util.concurrent.lock.ReentrantReadWriteLock ? synchronized 有 3种用法 修饰普通方法，执行方法代码，需要获取对象本身 this 的锁 package constxio
Java 中常见的锁有
? synchronized 有 3种用法
package constxiong.concurrency.a18; import java.util.ArrayList; import java.util.List; /** * 测试 synchronized 普通方法 * @author ConstXiong * @date 2019-09-19 10:49:46 */ public class TestSynchronizedNormalMethod { private int count = 0; // private void add1000() { private synchronized void add1000() { //使用 synchronized 修饰 add100 方法，即可获得正确的值 30000 for (int i = 0; i < 1000; i++) { count++; } } //启动 30 个线程，每个线程 对 TestSynchronized 对象的 count 属性加 1000 private void test() throws InterruptedException { List<Thread> threads = new ArrayList<Thread>(10); for (int i = 0; i < 30; i++) { Thread t = new Thread(() -> { add1000(); }); t.start(); threads.add(t); } //等待所有线程执行完毕 for (Thread t : threads) { t.join(); } //打印 count 的值 System.out.println(count); } public static void main(String[] args) throws InterruptedException { //创建 TestSynchronizedNormalMethod 对象，调用 test 方法 new TestSynchronizedNormalMethod().test(); } } ? ?
package constxiong.concurrency.a18; import java.util.ArrayList; import java.util.List; /** * 测试 synchronized 静态方法 * @author ConstXiong * @date 2019-09-19 10:49:46 */ public class TestSynchronizedStaticMethod { private static int count = 0; private static void add1000() { // private synchronized static void add1000() { //使用 synchronized 修饰 add100 方法，即可获得正确的值 30000 for (int i = 0; i < 1000; i++) { count++; } } public static void main(String[] args) throws InterruptedException { //启动 30 个线程，每个线程 对 TestSynchronized 对象的 count 属性加 1000 List<Thread> threads = new ArrayList<Thread>(10); for (int i = 0; i < 30; i++) { Thread t = new Thread(() -> { add1000(); }); t.start(); threads.add(t); } //等待所有线程执行完毕 for (Thread t : threads) { t.join(); } //打印 count 的值 System.out.println(count); } } ? ?
package constxiong.concurrency.a18; import java.util.ArrayList; import java.util.List; /** * 测试 synchronized 代码块 * @author ConstXiong * @date 2019-09-19 10:49:46 */ public class TestSynchronizedCodeBlock { private int count = 0; //锁定的对象 private final Object obj = new Object(); private void add1000() { //执行下面的加 1000 的操作，都需要获取 obj 这个对象的锁 synchronized (obj) { for (int i = 0; i < 1000; i++) { count++; } } } //启动 30 个线程，每个线程 对 TestSynchronized 对象的 count 属性加 1000 private void test() throws InterruptedException { List<Thread> threads = new ArrayList<Thread>(10); for (int i = 0; i < 30; i++) { Thread t = new Thread(() -> { add1000(); }); t.start(); threads.add(t); } //等待所有线程执行完毕 for (Thread t : threads) { t.join(); } //打印 count 的值 System.out.println(count); } public static void main(String[] args) throws InterruptedException { //创建 TestSynchronizedNormalMethod 对象，调用 test 方法 new TestSynchronizedCodeBlock().test(); } } ? ? ? 可重入锁 java.util.concurrent.lock.ReentrantLock 的使用示例package constxiong.concurrency.a18; import java.util.ArrayList; import java.util.List; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; /** * 测试 ReentrantLock * @author ConstXiong * @date 2019-09-19 11:26:50 */ public class TestReentrantLock { private int count = 0; private final Lock lock = new ReentrantLock(); private void add1000() { lock.lock(); try { for (int i = 0; i < 1000; i++) { count++; } } finally { lock.unlock(); } } //启动 30 个线程，每个线程 对 TestSynchronized 对象的 count 属性加 1000 private void test() throws InterruptedException { List<Thread> threads = new ArrayList<Thread>(10); for (int i = 0; i < 30; i++) { Thread t = new Thread(() -> { add1000(); }); t.start(); threads.add(t); } //等待所有线程执行完毕 for (Thread t : threads) { t.join(); } //打印 count 的值 System.out.println(count); } public static void main(String[] args) throws InterruptedException { //创建 TestReentrantLock 对象，调用 test 方法 new TestReentrantLock().test(); } } ? ?? 可重复读写锁 java.util.concurrent.lock.ReentrantReadWriteLock 的使用示例package constxiong.concurrency.a18; import java.util.HashMap; import java.util.Map; import java.util.Random; import java.util.concurrent.locks.ReadWriteLock; import java.util.concurrent.locks.ReentrantReadWriteLock; /** * 测试可重入读写锁 ReentrantReadWriteLock * @author ConstXiong * @date 2019-09-19 11:36:19 */ public class TestReentrantReadWriteLock { //存储 key value 的 map private Map<String,Object> map = new HashMap<String,Object>(); //读写锁 private final ReadWriteLock lock = new ReentrantReadWriteLock(); /** * 根据 key 获取 value * @param key */ public Object get(String key) { Object value = null; lock.readLock().lock(); try { Thread.sleep(50L); value = map.get(key); } catch (InterruptedException e) { e.printStackTrace(); } finally { lock.readLock().unlock(); } return value; } /** * 设置key-value * @param key */ public void set(String key,Object value) { lock.writeLock().lock(); try { Thread.sleep(50L); map.put(key,value); } catch (InterruptedException e) { e.printStackTrace(); } finally { lock.writeLock().unlock(); } } //测试5个线程读数据，5个线程写数据 public static void main(String[] args) { //创建测试可重入读写锁 TestReentrantReadWriteLock 对象 TestReentrantReadWriteLock test = new TestReentrantReadWriteLock(); String key = "lock";//存入 map 中的 key Random r = new Random();//生成随机数作为 value for (int i = 0; i < 5; i++) { //5 个线程读 map 中 key 的 value new Thread(() -> { for (int j = 0; j < 10; j++) { System.out.println(Thread.currentThread().getName() + " read value=" + test.get(key)); } }).start(); //5 个线程写 map 中 key 的 value new Thread(() -> { for (int j = 0; j < 10; j++) { int value = r.nextInt(1000); test.set(key,value); System.out.println(Thread.currentThread().getName() + " write value=" + value); } }).start(); } } } ? ? 锁的使用注意事项
Integer i = 100;
?? ??? ? Java面试题汇总，总有一道卡住你！
（编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |
