0
点赞
收藏
分享

微信扫一扫

并发编程-锁的深入化

上一篇 <<<线程安全与解决方案
下一篇 >>>锁的优化


synchronized--悲观锁、独占锁、互斥锁、排他锁
Lock分为ReentrantLock、读写锁、公平锁和非公平锁,底层用了CAS无锁机制(自旋锁)。
ReentrantLock锁底层使用AQS原理实现。

自旋锁与互斥锁的区别

重入锁

public  synchronized void get() {
    System.out.println("name:" + Thread.currentThread().getName() + " get();");
    set();
}
public synchronized  void set() {
    System.out.println("name:" + Thread.currentThread().getName() + " set();");
}

public void run() {
    get();
}
ReentrantLock lock = new ReentrantLock();
public void get() {
    lock.lock();
    System.out.println(Thread.currentThread().getId());
    set();
    lock.unlock();
}
public void set() {
    lock.lock();
    System.out.println(Thread.currentThread().getId());
    lock.unlock();
}

以上get和set方法调用的时候,都使用了同步锁,他们会自动传入,也就是类似于递归锁,不会互相排斥。

读写锁

public class ReadWriteLockTest {
    static Map<String, Object> map = new HashMap<String, Object>();
    static ReentrantReadWriteLock rwl = new ReentrantReadWriteLock();
    static Lock r = rwl.readLock();
    static Lock w = rwl.writeLock();

    // 获取一个key对应的value
    public static final Object get(String key) {
        r.lock();
        try {
            System.out.println(Thread.currentThread().getName()+" 正在做读的操作,key:" + key + " 开始");
            Thread.sleep(100);
            Object object = map.get(key);
            System.out.println(Thread.currentThread().getName()+" 正在做读的操作,key:" + key + " 结束");
            System.out.println();
            return object;
        } catch (InterruptedException e) {

        } finally {
            r.unlock();
        }
        return key;
    }

    // 设置key对应的value,并返回旧有的value
    public static final Object put(String key, Object value) {
        w.lock();
        try {

            System.out.println(Thread.currentThread().getName()+" 正在做写的操作,key:" + key + ",value:" + value + "开始.");
            Thread.sleep(100);
            Object object = map.put(key, value);
            System.out.println(Thread.currentThread().getName()+" 正在做写的操作,key:" + key + ",value:" + value + "结束.");
            System.out.println();
            return object;
        } catch (InterruptedException e) {

        } finally {
            w.unlock();
        }
        return value;
    }
    public static void main(String[] args) {
        new Thread(new Runnable() {
            public void run() {
                for (int i = 0; i < 10; i++) {
                    ReadWriteLockTest.put(i + "", i + "");
                }

            }
        }).start();
        new Thread(new Runnable() {
            public void run() {
                for (int i = 0; i < 10; i++) {
                    ReadWriteLockTest.get(i + "");
                }

            }
        }).start();
    }
}

公平锁和非公平锁

非公平锁效率比公平锁效率要高。Synchronized是非公平锁


悲观锁与乐观锁

独占锁与共享锁

行锁

查看锁的语句:
Select * from information_schema.innodb_trx;


如果begin了之后,没有commit或rollback,则开启新的时候会出现LOCK_WAIT的情况,手动删除命令:kill 11892.


首次执行生成的事务ID 是11892,二次来的时候是11895,在126的时候会提示无法获取到锁超时。

tips:MySQL更多的锁情况请参考:MySQL的表锁行锁及间隙锁

原子类

AtomicInteger atomic = new AtomicInteger();
atomic.incrementAndGet();

多线程使用的锁和原子类的锁有什么区别


相关文章链接:
<<<多线程基础
<<<线程安全与解决方案
<<<锁的优化
<<<Java内存模型(JMM)
<<<Volatile解决JMM的可见性问题
<<<Volatile的伪共享和重排序
<<<CAS无锁模式及ABA问题
<<<Synchronized锁
<<<Lock锁
<<<AQS同步器
<<<Condition
<<<CountDownLatch同步计数器
<<<Semaphore信号量
<<<CyclicBarrier屏障
<<<线程池
<<<并发队列
<<<Callable与Future模式
<<<Fork/Join框架
<<<Threadlocal
<<<Disruptor框架
<<<如何优化多线程总结

举报

相关推荐

0 条评论