Java学习教程-java多线程(代码版).docx

《Java学习教程-java多线程(代码版).docx》由会员上传分享，免费在线阅读，更多相关内容在工程资料-天天文库。

1、1） packagecom.sfpay.sypay.msp.process; publicinterfaceServiceHolder{ TgetService(); } 2） packagecom.sfpay.sypay.msp.process.service.impl; importjava.net.Inet4Address; importjava.net.InetAddress; importjava.net.NetworkInterface; importjava.util.ArrayList; 

2、importjava.util.Enumeration; importjava.util.List; importjava.util.concurrent.BlockingQueue; importjava.util.concurrent.atomic.AtomicBoolean; importorg.apache.commons.lang3.StringUtils; importorg.slf4j.Logger; importorg.slf4j.LoggerFactory; importcom.sfpay.s

3、ypay.msp.common.enums.StatusCode; importcom.sfpay.sypay.msp.dao.ICourierSfjSendDao; importcom.sfpay.sypay.msp.process.ServiceHolder; importcom.sfpay.sypay.order.service.IPrefBusinessService; importcom.sfpay.sypay.order.valueobject.dto.PrefBusinessRequest; im

4、portcom.sfpay.sypay.order.valueobject.dto.PrefBusinessResponse; /** *非线支付，给收派员送顺丰金任务 * *@authorsfhq703 * */ publicclassPrefSenderRunimplementsRunnable{ privateLoggerlogger=LoggerFactory.getLogger(PrefSenderRun.class); privateBlockingQueue

5、quest>>senderQueue=null; privateServiceHolderprefBusinessService;//发送奖励对象 privateServiceHoldercourierSfjSendDao; privateAtomicBooleanisTodayTaskCompletePref=null; privateintrunNum=0; privateAtomicBooleanisExecutePref

6、=null; /** * *@paramsenderQueue *           :下发队列 *@paramvoucherManagerService *           ：下游系统service *@paramcourierSfjSendDao *           ：发送DAO *@paramisTodayTaskComplete *           ：调度是否完成标示 */ publicPrefSenderRun(BlockingQueue

7、>>senderQueue, ServiceHolderprefBusinessService, ServiceHoldercourierSfjSendDao, AtomicBooleanisTodayTaskCompletePref,intrunNum, AtomicBooleanisExecutePref){ super(); this.senderQueue=senderQueue; this.prefBusinessSe

8、rvice=prefBusinessService; this.courierSfjSendDao=courierSfjSendDao; this.isTodayTaskCompletePref=isTodayTaskCompletePref; this.runNum=runNum; this.isExecutePref=isExecutePref; } @Override publi