辛い辛い.java

class 辛い {

	@SpyBean
	HogeService hogeService;

	@Test
	public void testHoge(){

		CyclicBarrier barrier = new CyclicBarrier(2);
		doAnswer(invocation -> {
			TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
				@Override
				public void afterCommit() {
					try {
					barrier.await();
					} catch (InterruptedException | BrokenBarrierException e) {
						throw new AssertionError(e);
					}
				}
			});
			return invocation.callRealMethod();
		}).when(hogeService)
			.hoge(any());

		barrier.await();
	}
}