Java多線程之同步鎖-lock詳解

更新時(shí)間：2022年10月08日 11:13:38 作者：小虛竹and掘金

這篇文章主要為大家詳細(xì)介紹了Java多線程中同步鎖-lock的原理與使用，文中的示例代碼講解詳細(xì)，對(duì)我們了解線程有一定幫助，需要的可以參考一下

一、題目描述

題目：

同步鎖出現(xiàn)的目的就是為了解決多線程安全問題。

同步鎖的幾種方式

synchronized

1、同步代碼塊

2、同步方法

jdk1.5后

3、lock鎖：用lock()上鎖，unlock()釋放鎖

實(shí)現(xiàn)：重現(xiàn)窗口售票多線程問題，并用lock鎖解決。

二、解題思路

重現(xiàn)窗口售票多線程問題：

新創(chuàng)建類：LockDemo1

在main方法中，新創(chuàng)建三個(gè)線程，一起啟動(dòng)這三個(gè)線程。

新創(chuàng)建內(nèi)部類：Ticket ， Ticket implements Runnable

Ticket中每0.2秒賣一張票，用--i

使用lock鎖：

新創(chuàng)建類：LockDemo2

在main方法中，新創(chuàng)建三個(gè)線程，一起啟動(dòng)這三個(gè)線程。

新創(chuàng)建內(nèi)部類：Ticket ， Ticket implements Runnable

在這段邏輯之前上鎖，邏輯結(jié)束后釋放鎖 要把釋放鎖放在finally里

Ticket中每0.2秒賣一張票，用--i

lock鎖相比于synchronized的好處是靈活，可由研發(fā)人員自行控制加鎖和解鎖的時(shí)機(jī)。

三、代碼詳解

LockDemo1

/**
 * Description: 重現(xiàn)窗口售票多線程問題
 *
 * @author xiaoxuzhu
 * @version 1.0
 *
 * <pre>
 * 修改記錄:
 * 修改后版本	        修改人		修改日期			修改內(nèi)容
 * 2022/5/15.1	    xiaoxuzhu		2022/5/15		    Create
 * </pre>
 * @date 2022/5/15
 */
public class LockDemo1 {

    public static void main(String[] args) {
        Ticket ticket = new Ticket();
        new Thread(ticket, "1號(hào)窗口").start();
        new Thread(ticket, "2號(hào)窗口").start();
        new Thread(ticket, "3號(hào)窗口").start();
    }

    static class Ticket implements Runnable {

        private int tick = 100;

        @Override
        public void run() {

            while (true) {
                try {
                    Thread.sleep(200);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                if (tick > 0) {
                    System.out.println(Thread.currentThread().getName() + "完成售票，余票是：" + --tick);
                }
            }
        }
    }
}

出現(xiàn)多線程問題：

LockDemo2

public class LockDemo2 {

    public static void main(String[] args) {
        Ticket ticket = new Ticket();
        new Thread(ticket, "1號(hào)窗口").start();
        new Thread(ticket, "2號(hào)窗口").start();
        new Thread(ticket, "3號(hào)窗口").start();
    }

    static class Ticket implements Runnable {

        private int tick = 100;
        //創(chuàng)建鎖
        private Lock lock = new ReentrantLock();

        @Override
        public void run() {

            while (true) {
                //上鎖
                lock.lock();
                try {
                    try {
                        Thread.sleep(200);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    if (tick > 0) {
                        System.out.println(Thread.currentThread().getName() + "完成售票，余票是：" + --tick);
                    }
                }finally {
                    lock.unlock();
                }
            }
        }
    }
}