Java中的Locks如何使用 | java.util.concurrent.locks.Lock教程和示例

我们已经了解了线程同步的基本概念以及使用synchronized关键字的各种机制。Java提供了另一种基于Lock接口和实现它的类(例如ReentrantLock)的代码块同步机制。在本教程中,我们将看到Lock用于解决打印机队列问题的接口的基本用法。

Lock接口

java.util.concurrent.locks.Lock是与synchronization一样的线程同步机制。然而,Locksynchronization更灵活,更复杂。由于Lock是一个接口,您需要使用其中一个实现来在您的应用程序中使用LockReentrantLockLock接口的一个这样的实现。

下面Lock接口的简单使用。

Lock lock = new ReentrantLock();
lock.lock();
//critical section
lock.unlock();

首先创建一个Lock。然后调用它的lock()方法。现在Lock实例已被锁定了。在已锁定的线程调用unlock()之前,将阻止任何其他线程调用lock()。最后调用unlock(),现在Lock解锁了,所以其他线程就可以锁定它。

Lock接口和synchronized关键字之间的区别

Locksynchronized块之间的主要区别是:

  1. 尝试访问synchronized块时超时是不可能的。使用Lock.tryLock(long timeout, TimeUnit timeUnit),这是可以的。
  2. synchronized块必须完全包含在一个方法中。Lock可以在不同的方法中调用lock()unlock()

使用Locks模拟打印机队列

在此示例中,程序将模拟打印机的行为。您可以在不同的时间间隔内或同时向打印机提交许多打印作业。打印机将从打印机队列中取出作业并打印出来。其余的工作将在那里等待轮到他们。一旦打印机完成了打印作业,它将从队列中选择另一个作业并开始打印。保持这种情况不断循环。

PrintingJob.java

此类表示可以提交给打印机的独立打印。这个类实现了Runnable接口,因此打印机可以在掉头时执行它。

public class PrintingJob implements Runnable {
    private PrinterQueue printerQueue;

    public PrintingJob(PrinterQueue printerQueue) {
        this.printerQueue = printerQueue;
    }

    public void run() {
        System.out.printf("%s: Going to print a document\n", Thread.currentThread().getName());
        printerQueue.printJob(new Object());
    }
}

PrinterQueue.java

此类表示打印机队列/打印机。当前打印作业完成后,打印机将保持锁定以启动新的打印作业。

public class PrinterQueue {
    private final Lock queueLock = new ReentrantLock();

    public void printJob(Object document) {
        queueLock.lock();
        try {
            Long duration = (long) (Math.random() * 10000);
            System.out.println(Thread.currentThread().getName() + ": PrintQueue: Printing a Job during   " + (duration / 1000) + " seconds :: Time - " + new Date());
            Thread.sleep(duration);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            System.out.printf("%s: The document has been printed\n", Thread.currentThread().getName());
            queueLock.unlock();
        }
    }
}

我们来测试我们的打印机程序:

public class LockExample {
    public static void main(String[] args)
    {
        PrinterQueue printerQueue = new PrinterQueue();
        Thread thread[] = new Thread[10];
        for (int i = 0; i < 10; i++)
        {
            thread[i] = new Thread(new PrintingJob(printerQueue), "Thread " + i);
        }
        for (int i = 0; i < 10; i++)
        {
            thread[i].start();
        }
    }
}

输出结果为:

Thread 1: Going to print a document
Thread 0: Going to print a document
Thread 9: Going to print a document
Thread 8: Going to print a document
Thread 7: Going to print a document
Thread 6: Going to print a document
Thread 5: Going to print a document
Thread 4: Going to print a document
Thread 3: Going to print a document
Thread 2: Going to print a document
Thread 1: PrintQueue: Printing a Job during   5 seconds :: Time - Sun Mar 03 01:29:27 CST 2019
Thread 1: The document has been printed
Thread 0: PrintQueue: Printing a Job during   6 seconds :: Time - Sun Mar 03 01:29:32 CST 2019
Thread 0: The document has been printed
Thread 9: PrintQueue: Printing a Job during   9 seconds :: Time - Sun Mar 03 01:29:39 CST 2019
Thread 9: The document has been printed
Thread 8: PrintQueue: Printing a Job during   6 seconds :: Time - Sun Mar 03 01:29:48 CST 2019
Thread 8: The document has been printed
Thread 7: PrintQueue: Printing a Job during   4 seconds :: Time - Sun Mar 03 01:29:54 CST 2019
Thread 7: The document has been printed
Thread 6: PrintQueue: Printing a Job during   6 seconds :: Time - Sun Mar 03 01:29:58 CST 2019
Thread 6: The document has been printed
Thread 5: PrintQueue: Printing a Job during   3 seconds :: Time - Sun Mar 03 01:30:05 CST 2019
Thread 5: The document has been printed
Thread 4: PrintQueue: Printing a Job during   2 seconds :: Time - Sun Mar 03 01:30:08 CST 2019
Thread 4: The document has been printed
Thread 3: PrintQueue: Printing a Job during   2 seconds :: Time - Sun Mar 03 01:30:10 CST 2019
Thread 3: The document has been printed
Thread 2: PrintQueue: Printing a Job during   1 seconds :: Time - Sun Mar 03 01:30:13 CST 2019
Thread 2: The document has been printed

该示例的关键在于PrinterQueue类的printJob()方法。当我们想要使用锁实现一个关键部分并保证只有一个执行线程运行一个代码块时,我们必须创建一个ReentrantLock对象。在临界区的开头,我们必须使用lock()方法来控制锁。

在关键部分的末尾,我们必须使用unlock()方法来释放锁的控制并允许其他线程运行此关键部分。如果不在临界区末尾调用unlock()方法,则等待该块的其他线程将永远等待,从而导致死锁情况。如果在关键部分使用try-catch块,请不要忘记将包含unlock()方法的句子放在finally部分中。

阅读更多:如何创建死锁并在java中解决它

你必须非常小心使用Locks以避免死锁。当两个或多个线程被阻塞等待永远不会被解锁的锁时会发生这种情况。例如,线程(A)锁定Lock (X),线程(B)锁定Lock (Y)。如果现在,线程(A)尝试锁定锁定(Y)并且线程(B)同时尝试锁定锁定(X),两个线程将无限期地被阻塞,因为它们正在等待永远不会被释放的锁定。请注意,这个问题出现,是因为两个线程都试图以相反的顺序获取锁。

参考资料
How to Use Locks in Java | java.util.concurrent.locks.Lock Tutorial and Example

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 200,612评论 5 471
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 84,345评论 2 377
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 147,625评论 0 332
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,022评论 1 272
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 62,974评论 5 360
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,227评论 1 277
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,688评论 3 392
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,358评论 0 255
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,490评论 1 294
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,402评论 2 317
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,446评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,126评论 3 315
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,721评论 3 303
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,802评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,013评论 1 255
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,504评论 2 346
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,080评论 2 341

推荐阅读更多精彩内容