Spring的事务管理难点剖析(4):多线程的困惑

启动独立线程调用事务方法

package com.baobaotao.multithread;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.stereotype.Service;
import org.apache.commons.dbcp.BasicDataSource;@Service("userService")
public class UserService extends BaseService {@Autowiredprivate JdbcTemplate jdbcTemplate;@Autowiredprivate ScoreService scoreService;public void logon(String userName) {System.out.println("before userService.updateLastLogonTime method...");updateLastLogonTime(userName);System.out.println("after userService.updateLastLogonTime method...");//scoreService.addScore(userName, 20);//①在同一线程中调用scoreService#addScore()//②在一个新线程中执行scoreService#addScore()Thread myThread = new MyThread(this.scoreService, userName, 20);//使用一个新线程运行myThread.start();}public void updateLastLogonTime(String userName) {String sql = "UPDATE t_user u SET u.last_logon_time = ? WHERE user_name =?";jdbcTemplate.update(sql, System.currentTimeMillis(), userName);}//③负责执行scoreService#addScore()的线程类private class MyThread extends Thread {private ScoreService scoreService;private String userName;private int toAdd;private MyThread(ScoreService scoreService, String userName, int toAdd) {this.scoreService = scoreService;this.userName = userName;this.toAdd = toAdd;}public void run() {try {Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("before scoreService.addScor method...");scoreService.addScore(userName, toAdd);System.out.println("after scoreService.addScor method...");}}
}

将日志级别设置为DEBUG，执行UserService#logon()方法，观察以下输出日志：