java异步执行代码处理方法(先返回结果,后执行代码).docx

第

java异步执行代码处理方法(先返回结果,后执行代码)

目录业务场景：处理1：简单异步处理2：多个异步执行总结：

业务场景：

在用户那，角色那变更后，要更新数据，因为更新要比较长时间，需要先返回结果（2:已接收待执行）。更新结束后，再返回值结果。

（执行结果.0:执行失败；1:执行成功；2:已接收待执行）

处理1：简单异步

使用ExecutorService异步

publicvoidonCallback(JSONObjectparam){

ExecutorServiceexecutor=Executors.newCachedThreadPool();

executor.execute(()-{

try{

Thread.sleep(1000*10);

}catch(InterruptedExceptione){

e.printStackTrace();

//这边执行具体的方法

this.syncDealResult(param);

executor.shutdown();

publicJSONObjectdealResult(JSONObjectparams){

//先返回结果，然后异步执行

this.onCallback(params);

JSONObjectresult=newJSONObject();

result.put(excRs,2);

returnresult;

publicvoidsyncDealResult(JSONObjectparams){

(dealabRoleparam{},JSON.toJSONString(params));

StringlogId=MapUtils.getString(params,logId);

StringexcRs=1;

try{

//具体操作

}catch(Exceptione){

e.printStackTrace();

excRs=-1;

(updateabRolefinishcallRecordId{},excRs{},logId,excRs);

//处理完后推送结果

JSONObjectparam=newJSONObject();

param.put(logId,logId);

param.put(excRs,excRs);

//推送结果

}

加Thread.sleep(1000*10);就明显看得出差别了。

如果是有多种异步执行，比如：A执行完后，B要做通知；C要入库；D要做统计，这时候要怎么处理呢？

处理2：多个异步执行

IRoleCallback

importcom.alibaba.fastjson.JSONObject;

importmons.lang3.StringUtils;

*AB角色异步调用接口

publicinterfaceIRoleCallback{

*Computesaresult,orthrowsanexceptionifunabletodoso.

*@paramparam结果

*@returncomputedresult

*@throwsExceptionifunabletocomputearesult

Objectcall(JSONObjectparam)throwsException;

*uniquenameofcallback

*@returncallbackname

defaultStringname(){

returnStringUtils.uncapitalize(getClass().getSimpleName());

*priortocallback用于排序

*@returnorder

defaultdoubleorder(){

return1.0d;

}

RoleCallbackRegister

importjava.util.*;

publicclassRoleCallbackRegister{

privatestaticfinalMapString,IRoleCallbackCALL