java使用wait()和notify()线程间通讯的实现

    public static void main(String[] args) throws InterruptedException {
        final Thread main = Thread.currentThread();
        main.setName("main thread");
        // 创建一个默认定时任务
        ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(
                5,  // 核心线程数
                new ThreadPoolExecutor.CallerRunsPolicy()  // 队列满后的拒绝策略
        );
        AtomicInteger flag = new AtomicInteger(0);
        // 执行定时任务
        final ScheduledFuture<?> queryTask = executor.scheduleAtFixedRate(() -> {
            // 在这里执行您的定时任务逻辑
            final int i = flag.addAndGet(1);
            log.info("定时任务执行了1！flag={}", i);
            if (i == 5) {
                synchronized (main) {
                    System.out.println("通知主线程取消该任务");
                    main.notify();
                }
            }
        }, 0, 3, TimeUnit.SECONDS);
        final ScheduledFuture<?> printTask = executor.scheduleAtFixedRate(() -> {
            // 在这里执行您的定时任务逻辑
            log.info("定时任务执行了2！");
        }, 0, 3, TimeUnit.SECONDS);
        log.info("main wait");
        synchronized (main) {
            /**
             *
             主线程在执行 main.wait() 进入等待状态后，确实会释放 main 对象的锁，而不是一直占用锁。
             这是 Java 中 wait() 方法的特性之一。
             当一个线程调用 wait() 方法时，它会释放对象的锁，让其他线程可以获得这个锁并执行相应的同步代码块。
             */
            main.wait();
        }
        log.info("main 活了");
        // 取消定时任务
        queryTask.cancel(true);
        log.info("scheduledFuture被取消");
    }