@Autowired

private ThreadPoolTaskExecutor threadPoolTaskExecutor;

threadPoolTaskExecutor.execute(new UpdateDbCdkeyStatus(AcvitityId, couponCode, money));

/**

* 記錄coupon到數據庫

*/

private class UpdateDbCdkeyStatus implements Runnable {

private String couponCode;

private int money;

private int activityId;

public UpdateDbCdkeyStatus(int activityId, String couponCode, int money) {

this.activityId = activityId;

this.couponCode = couponCode;

this.money = money;

}

@Override

public void run() {

insertEventService.insertCdKey(couponCode, money, STATUS_NORMAL, AcvitityId, "chinaMobile");;

}

}

總結

以上是生活随笔為你收集整理的java mysql 异步查询数据库_java 异步操作数据库的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。