Javaにおけるメソッドの排他制御について

#前提
とあるSpring Bootアプリケーションを作成しています。
@Asyncアノテーションを付与することで、一部のサービスを非同期実行可能にしています。
しかし、その非同期実行の先で、一つのメソッド（以下、Aメソッド）に関しては排他制御をかけなければならないことが分かりました。

Aメソッドにはint型の引数があります。
１～８のいずれかが渡される予定です。

#分からないこと
引数で渡された数値を確認し、
現在Aメソッドが処理中の数値と同じものであれば、排他制御をかけたいと思っています。

つまり

引数１でAメソッド実行開始
引数２でAメソッド実行開始
引数７でAメソッド実行開始
引数２のAメソッド実行終了
引数２でAメソッド実行開始
引数７でAメソッド実行開始

上記の「状態6」の時点で排他制御をかけ、Aメソッド実行を待機させたいと考えています。
（もちろん、１、２、７以外の数値が引数で来た場合は、処理を開始します）
このような複雑な排他制御をかけるには、どうすれば良いでしょうか。

int型を引数に持つ他のメソッドをもう一つ作成し、Aメソッドを実行するかどうかを
そこで決める、なども考えたのですが・・・イマイチ実現する方法が分かりませんでした。
（Synchronizedを使えば実現できるのでしょうか・・・）

どなたかご教授願います。

xebme

2019/08/29 11:17

synchronizer token とか token と呼ばれるパターンを調べてください。

131505_01180109

2019/08/30 00:12

調査してみます。

行動規範の内容に同意します

回答1件

ベストアンサー

かなり適当ですが...

java
1import java.util.ArrayList;
2import java.util.List;
3
4public class Sync {
5  public static void main(String args[]) throws InterruptedException {
6    new Thread(new Runnable(){public void run(){new Sync().A(1, 5000);}}).start();
7    new Thread(new Runnable(){public void run(){new Sync().A(2, 1000);}}).start();
8    new Thread(new Runnable(){public void run(){new Sync().A(7, 3000);}}).start();
9    new Thread(new Runnable(){public void run(){try{Thread.sleep(2000);}catch(InterruptedException e){}; new Sync().A(2, 1000);}}).start();
10    Thread t = new Thread(new Runnable(){public void run(){new Sync().A(7, 3000);}});
11    t.start();
12    t.join();
13  }
14
15  private static List<Integer> lockList = new ArrayList<>();
16  void A(int num, long millis) {
17    try {
18      synchronized (lockList) {
19        while(lockList.contains(Integer.valueOf(num))) lockList.wait();
20        lockList.add(Integer.valueOf(num));
21      }
22
23      try {
24        System.out.println("引数"+num+"でAメソッド実行開始");
25
26        //処理
27        Thread.sleep(millis);
28
29        System.out.println("引数"+num+"でAメソッド実行終了");
30
31      } finally {
32        synchronized (lockList) {
33          lockList.remove(Integer.valueOf(num));
34          lockList.notifyAll();
35        }
36      }
37
38    } catch (InterruptedException e) {
39      e.printStackTrace();
40    }
41  }
42}