Leetcode 1114 - 按序打印

Leetcode 1114 - 按序打印 - 题解以及解析
<!--more-->html

题目描述

咱们提供了一个类:java

public class Foo {
  public void one() { print("one"); }
  public void two() { print("two"); }
  public void three() { print("three"); }
}

三个不一样的线程将会共用一个 Foo 实例。api

  • 线程 A 将会调用 one() 方法
  • 线程 B 将会调用 two() 方法
  • 线程 C 将会调用 three() 方法

请设计修改程序,以确保 two() 方法在 one() 方法以后被执行,three() 方法在 two() 方法以后被执行。并发

示例 1:oracle

  • 输入: [1,2,3]
  • 输出: "onetwothree"
  • 解释:

有三个线程会被异步启动。
输入 [1,2,3] 表示线程 A 将会调用 one() 方法,线程 B 将会调用 two() 方法,线程 C 将会调用 three() 方法。
正确的输出是 "onetwothree"。
示例 2:异步

  • 输入: [1,3,2]
  • 输出: "onetwothree"
  • 解释:

输入 [1,3,2] 表示线程 A 将会调用 one() 方法,线程 B 将会调用 three() 方法,线程 C 将会调用 two() 方法。
正确的输出是 "onetwothree"。
 
注意: 尽管输入中的数字彷佛暗示了顺序,可是咱们并不保证线程在操做系统中的调度顺序。你看到的输入格式主要是为了确保测试的全面性。测试

提交答案

class Foo {
    public Foo() {}

    private Semaphore first = new Semaphore(0);
    private Semaphore second = new Semaphore(0);
    private Semaphore third = new Semaphore(0);

    public void first(Runnable printFirst) throws InterruptedException {
        // printFirst.run() outputs "first". Do not change or remove this line.
        printFirst.run();
        first.release();
        second.release();
    }

    public void second(Runnable printSecond) throws InterruptedException {
        // printSecond.run() outputs "second". Do not change or remove this line.
        second.acquire();
        printSecond.run();
        second.release();
        third.release();
    }

    public void third(Runnable printThird) throws InterruptedException {
        // printThird.run() outputs "third". Do not change or remove this line.
        third.acquire();
        printThird.run();
        third.release();
    }
}
执行用时: 12 ms , 在全部 Java 提交中击败了 74.80% 的用户

内存消耗: 39.3 MB , 在全部 Java 提交中击败了 5.60% 的用户ui

题解反思

这道题主要的解题思路就是采用了三个初始化 permit0 的信号量。这样在程序启动时,刚开始 second.acquire() third.acquire() 均不会获取到线程资源,直到 first 执行完 run() 方法后,才会释放第二个信号量,这时 second.acquire() 才能获取到信号量,继而 printSecond.run() ,以后 second 又会释放第三个信号量,一样这时 third.acquire() 才可以获取到信号量,从而成功执行 printThird.run(),经过这样的方式,保证了线程的按许执行。this

这里贴一下 Java 中信号量 Semaphore 的官方接口文档,可供查阅。https://docs.oracle.com/javase/8/docs/api/index.html?java/util/concurrent/Semaphore.html操作系统

在并发问题中,他们都有一个共同的特征,即:多个线程/进程之间共享某些资源,从而致使并发访问时的冲突。因为在程序中没法消除全部对共享资源的依赖,在这种状况下,防止并发问题就变成了共享资源的协调问题了。所以,解决这类问题其中最核心的思想就是要保证共享资源在某个时刻只能有一个线程/进程访问,也就是确保系统中关键代码的独占性,这样就能够防止程序进入不一致的状态。

最后,再推荐一篇信号量相关的教程。👉 Semaphores in Java

本文首发于「 愚一笔记