This commit is contained in:
linfso 2024-11-21 19:15:06 +08:00
parent e2baa7ee32
commit 5aef70e088

View File

@ -114,6 +114,7 @@ public class EmisCommissionProfitServiceImpl extends EmisBaseService implements
class MultiDoThread implements Runnable { class MultiDoThread implements Runnable {
private List<EmisWaybill> dataList = null; private List<EmisWaybill> dataList = null;
private CountDownLatch latch = null; private CountDownLatch latch = null;
private String name;
public MultiDoThread( public MultiDoThread(
List<EmisWaybill> dataList, List<EmisWaybill> dataList,
@ -122,6 +123,7 @@ public class EmisCommissionProfitServiceImpl extends EmisBaseService implements
){ ){
this.dataList = dataList; this.dataList = dataList;
this.latch = latch; this.latch = latch;
this.name=name;
} }
private void doData(){ private void doData(){
@ -136,12 +138,12 @@ public class EmisCommissionProfitServiceImpl extends EmisBaseService implements
} }
long end4 = System.currentTimeMillis(); long end4 = System.currentTimeMillis();
log.info(name+" escape time xxxx666:" + (end4 - start) + "ms"); log.info(this.name+" escape time xxxx666:" + (end4 - start) + "ms");
} }
@Override @Override
public void run() { public void run() {
log.debug(name+":Do profit thread start!"); log.debug(this.name+":Do profit thread start!");
try { try {
doData(); doData();
}catch(Exception ex){ }catch(Exception ex){
@ -149,7 +151,7 @@ public class EmisCommissionProfitServiceImpl extends EmisBaseService implements
} }
latch.countDown(); latch.countDown();
log.debug(name+":Do profit thread thread end!"); log.debug(this.name+":Do profit thread thread end!");
} }
} }