## 一、概述 比如輪詢大量的記錄，這種job，可能會一次輪詢耗時數個小時到數天，那么，對于業務來說，是無法接受的；這個時候，平臺支持通過引入派生多線程的并發解決方案； ## 二、解決方案 通過動態派生多線程來實現，通過一個例子，來參考實現； #### **調用核心邏輯** ``` SynCardDataApi api = getJobLogicTransactionalApi("synCardDataApi"); StringBuffer hql = new StringBuffer("from CardInfo where USER_ID >0"); List<CardInfo> cardlist = manager.getTransactionalCardDao().querySimpleHql(hql.toString()); List<List<CardInfo>> cardpackageList = ListUtil.splitListByPerListSize(cardlist, 1000); int threadNum = cardpackageList.size(); new SynCardDataRunCaller().call(threadNum, cardpackageList, api, manager, jobexecution); ``` #### **派生調用類** ``` public static class SynCardDataRunCaller extends TemporyTaskCaller { @Override public void createThreadToExecutionTask(int threadNum, ExecutorService executor, CountDownLatch currentMainThreadLatch, Object[] callerTranferdBusinessObjects) { for (int i = 0; i < threadNum; i++) { List<List<CardInfo>> cardpackageList = getBusinessObject(0); List<CardInfo> cardinfolistPer = cardpackageList.get(i); Runnable task = new SynCardDataRunThread(currentMainThreadLatch, appendToEndOfCallerTranferdBusinessObjects(cardinfolistPer)); executor.execute(task); } } } ``` #### **派生線程類** ``` public static class SynCardDataRunThread extends TemporyTaskThread { public SynCardDataRunThread(CountDownLatch callerCountDownLatch, Object[] callerTranferdBusinessObjects) { super(callerCountDownLatch, callerTranferdBusinessObjects); } @Override public void doBusinessInThread(Object[] callerTranferdBusinessObjects) { logger.error("{}開始運行", Thread.currentThread().getName()); SynCardDataApi api = getBusinessObject(1); JobManager manager = getBusinessObject(2); JobExecution jobexecution = getBusinessObject(3); jobexecution.append("{}開始運行", Thread.currentThread().getName()); List<CardInfo> cardlist = getBusinessObject(4); for (CardInfo cardinfo : cardlist) { try { api.doProcess(manager, cardinfo, jobexecution); } catch (Exception ex) { UniframeworkLogUtil.logJobException(ex); } } logger.error("{}完成運行", Thread.currentThread().getName()); } } ```