130131132133134135136137138139140
} @Test public void testAdjustThreadPool() throws Exception { SleepStage ss = new SleepStage("abcdef", 123); ss.adjustThreadPool(); ss.adjustThreadPool(); ss.adjustThreadPool(); ss.shutdown(); Field f = Stage.class.getDeclaredField("lastAdjustTime"); f.setAccessible(true);
131132133134135136137138139140141
@Test public void testAdjustThreadPool() throws Exception { SleepStage ss = new SleepStage("abcdef", 123); ss.adjustThreadPool(); ss.adjustThreadPool(); ss.adjustThreadPool(); ss.shutdown(); Field f = Stage.class.getDeclaredField("lastAdjustTime"); f.setAccessible(true); f.setLong(ss, 100);
132133134135136137138139140141142
@Test public void testAdjustThreadPool() throws Exception { SleepStage ss = new SleepStage("abcdef", 123); ss.adjustThreadPool(); ss.adjustThreadPool(); ss.adjustThreadPool(); ss.shutdown(); Field f = Stage.class.getDeclaredField("lastAdjustTime"); f.setAccessible(true); f.setLong(ss, 100); ss.adjustThreadPool();
137138139140141142143144145146147
ss.adjustThreadPool(); ss.shutdown(); Field f = Stage.class.getDeclaredField("lastAdjustTime"); f.setAccessible(true); f.setLong(ss, 100); ss.adjustThreadPool(); ss.adjustThreadPool(); } /** * Test method for {@link org.apache.niolex.commons.seda.Stage#dropMessage()}.
138139140141142143144145146147148
ss.shutdown(); Field f = Stage.class.getDeclaredField("lastAdjustTime"); f.setAccessible(true); f.setLong(ss, 100); ss.adjustThreadPool(); ss.adjustThreadPool(); } /** * Test method for {@link org.apache.niolex.commons.seda.Stage#dropMessage()}. *