前回はLockの使いかを確認したので、今回は少し実践的なことをやってみます。

ロックが必要となるケースは、例えば同じ伝票を同時に更新した時など、同時に更新する可能性がある処理に対して行うものです。

今回の対象となるSlipクラスです。typeは伝票の種類を文字列で表して、userNameは更新ユーザーの名前を登録します。

@Getter
@Setter
public class Slip extends SlipLock{

	private int id;
	
	private String type;
	
	private String userName;
		
	public Slip(int id, String type, String userName) {
		this.id = id;
		this.type = type;
		this.userName = userName;
	}

}

継承しているSlipLockクラスはReentrantLockを持っているだけです。ここは正直微妙なんで使いやすいようにしてもよいです。ReentrantLockを使った処理を書いてるだけです。

public abstract class SlipLock {
	
	protected final ReentrantLock lock = new ReentrantLock();
	
	public void lock() {
		this.lock.lock();
	}
	
	public void unlock() {
		lock.unlock();
	}
	
	public boolean tryLock() {
		return this.lock.tryLock();
	}
	
	public boolean tryLock(long time,TimeUnit unit) {
		boolean lock = false;
		try {
			lock = this.lock.tryLock(time, unit);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return lock;
	}
}

これらのSlipを使うユーザークラスは以下のようになっています

@Data
public class RegisterUser implements Runnable{
	
	private String name;
	
	private int updateId;
	
	public RegisterUser(String name, int updateId) {
		this.name = name;
		this.updateId = updateId;
	}
	
	@Override
	public void run() {
		SlipLogic logic = new SlipLogic();
		logic.updateSlip(this);
	}
}

Slipクラスを取得するRepositoryクラスを作成します。データアクセスは行いませんので簡易的にSlipを用意しています。

Slipを更新するには3秒ほどかかります

public class SlipRepository {

	private static SlipRepository repo = new SlipRepository();
	
	private Map<Integer, Slip> map = new HashMap<>();
	
	private SlipRepository() {
		map.put(1, new Slip(1, "売上" , "admin"));
		map.put(2, new Slip(2, "売上" , "admin"));
		map.put(3, new Slip(3, "売上" , "admin"));
		map.put(4, new Slip(4, "売上" , "admin"));
		map.put(5, new Slip(5, "受注" , "admin"));
		map.put(6, new Slip(6, "受注" , "admin"));
		map.put(7, new Slip(7, "受注" , "admin"));
		map.put(8, new Slip(8, "受注" , "admin"));
	}
	
	public static SlipRepository getInstance() {
		return repo;
	}
	
	public Slip getSlipById(int id) {
		return this.map.get(id);
	}
		
	public void updateSlipById(int id, Slip slip) {
		Slip rec = map.replace(id, slip);
		if(rec == null) {
			System.out.println("存在しないレコードです");
			return;
		}
		try {
			Thread.sleep(3000);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

	public void info() {
		System.out.println(this.map);
	}
}

Mainクラスでユーザーを作成してrunしてみます。

public static void main(String[] args) {
		
		List<Thread> threads = new ArrayList<>();
		
		
		SlipRepository repo = SlipRepository.getInstance();
		
		System.out.println(repo.getSlipById(1).getId() + repo.getSlipById(1).getUserName());
		System.out.println(repo.getSlipById(2).getId() + repo.getSlipById(2).getUserName());
		
		List<RegisterUser> users = List.of(
				new RegisterUser("澁谷かのん",1),
				new RegisterUser("嵐千砂都.",1),
				new RegisterUser("唐可可",2),
				new RegisterUser("平安名すみれ",2),
				new RegisterUser("葉月恋",1)
			);
		
		for(RegisterUser user: users) {
			Thread t = new Thread(user);
			t.start();
			threads.add(t);
		}
		
		// スレッドの終了を待ちます。
		threads.forEach(t -> {
			try {
				t.join();
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		});
		
		System.out.println(repo.getSlipById(1).getId() + repo.getSlipById(1).getUserName());
		System.out.println(repo.getSlipById(2).getId() + repo.getSlipById(2).getUserName());
	}

結果を見てみます

1admin
2admin
ロックを取得しましたロックユーザー = 澁谷かのん
ロックを取得しましたロックユーザー = 唐可可
ロックを取得しましたロックユーザー = 平安名すみれ
ロックを取得しましたロックユーザー = 嵐千砂都.
ロックされています失敗ユーザー = 葉月恋
1嵐千砂都.
2平安名すみれ

２回目

1admin
2admin
ロックを取得しましたロックユーザー = 嵐千砂都.
ロックを取得しましたロックユーザー = 平安名すみれ
ロックを取得しましたロックユーザー = 葉月恋
ロックを取得しましたロックユーザー = 唐可可
ロックされています失敗ユーザー = 澁谷かのん
1葉月恋
2唐可可

ロック対象となるSlipはid1とid2のものです。それぞれ更新処理時にはロックがかかりますので、待機時間内に処理が終わらずロックが取得できないユーザーは処理に失敗します。

Java | ロック処理の実践