public class FaultServiceTest extends TestCase { /** * @param args * @throws FaultException * @throws ExpParamNotFoundException * @throws ParseException */ private IFaultService faultService; private static final int NUM_THREAD = 100; // 測試線程總數 public FaultServiceTest() { super(); IInitService initService = (IInitService) CustomBeanFactory .getBean("initService"); initService.initSiteDatabase(); this.faultService = (IFaultService) CustomBeanFactory .getBean("faultService"); } public FaultServiceTest(String name) { super(name); IInitService initService = (IInitService) CustomBeanFactory .getBean("initService"); initService.initSiteDatabase(); this.faultService = (IFaultService) CustomBeanFactory .getBean("faultService"); } // 高并發測試 public void testGetEquipEventAlertListByPage() throws Throwable { EquipmentQueryBean equipmentQueryBean = new EquipmentQueryBean(); // 生成所有測試線程 TestRunnable[] test = new TestRunnable[NUM_THREAD]; long start = System.currentTimeMillis(); for (int i = 0; i < test.length; i++) { test[i] = new FaultServiceThread(faultService, equipmentQueryBean); } // 生成測試線程運行器 MultiThreadedTestRunner mttr = new MultiThreadedTestRunner(test); // 運行測試線程 mttr.runTestRunnables(); long used = System.currentTimeMillis() - start; System.out.printf("%s 調用花費 %s milli-seconds.\n", NUM_THREAD, used); } public static Test suite() { TestSuite test = new TestSuite("HealthService接口類測試"); test.addTest(new FaultServiceTest("testGetEquipEventAlertListByPage")); return test; } /* * 測試線程類定義 */ private static class FaultServiceThread extends TestRunnable { private IFaultService faultService; private EquipmentQueryBean equipmentQueryBean; public FaultServiceThread(IFaultService faultService, EquipmentQueryBean equipmentQueryBean) { super(); this.faultService = faultService; this.equipmentQueryBean = equipmentQueryBean; } @Override public void runTest() throws Throwable { faultService.getEquipEventAlertListByPage(equipmentQueryBean); } } ｝ |