package helper;

import com.yanzuoguang.util.helper.YzgTimeout;
import com.yanzuoguang.util.thread.ThreadHelper;
import org.junit.Test;

public class TestTimeout {

    public static final int WAIT_TIME = 1 * 60 * 1000;

    @Test
    public void test() {
        YzgTimeout.timeOut(TestTimeout.class, "消息", () -> {
            System.out.println("开始运行");
            ThreadHelper.sleep(WAIT_TIME);
            System.out.println("结束运行");
        }, (time) -> {
            // System.err.println("已经等待" + time);
        });
    }

    @Test
    public void testQueue() {
        for (int i = 0; i < 5000; i++) {
            ThreadHelper.runThread(() -> test());
        }
        ThreadHelper.sleep(WAIT_TIME * 2);
    }
}