阻塞线程的单元测试方法

import org.junit.jupiter.api.Test;
import org.mockito.Mockito;

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

import static org.mockito.Mockito.*;

public class BlockingTest {

    @Test
    public void testBlockingOperation() throws InterruptedException {
        // 创建一个锁对象
        Lock lock = Mockito.mock(Lock.class);

        // 模拟锁的获取操作
        when(lock.tryLock()).thenReturn(false, true); // 第一次返回false，第二次返回true

        // 调用阻塞操作
        boolean result = performBlockingOperation(lock);

        // 验证结果
        assert(result);
        verify(lock, times(2)).tryLock(); // 验证tryLock方法被调用了两次
    }

    private boolean performBlockingOperation(Lock lock) throws InterruptedException {
        while (!lock.tryLock()) {
            Thread.sleep(100); // 模拟阻塞等待
        }
        return true;
    }
}