private void assertSchedulerCalled(int times) {
        assertEquals(times, schedulerScheduleCalled);
    }
Should be called at the beginning of each test to initialize the manager.
core/src/test/java/kafka/automq/backpressure/DefaultBackPressureManagerTest.java