Spring代码实现：

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.stereotype.Component;

import org.springframework.transaction.support.TransactionSynchronizationAdapter;

import org.springframework.transaction.support.TransactionSynchronizationManager;

import java.util.ArrayList;

import java.util.List;

import java.util.concurrent.Executor;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

/**

* 事务完成之后再执行操作

*/

@Component

public class AfterCommitExecutor extends TransactionSynchronizationAdapter implements Executor{

private static final Logger LOGGER = LoggerFactory.getLogger(AfterCommitExecutorImpl.class);

private static final ThreadLocal> RUNNABLES = new ThreadLocal>();

private ExecutorService threadPool = Executors.newFixedThreadPool(5);

@Override

public void execute(Runnable runnable) {

LOGGER.info("Submitting new runnable {} to run after commit", runnable);

if (!TransactionSynchronizationManager.isSynchronizationActive()) {

LOGGER.info("Transaction synchronization is NOT ACTIVE. Executing right now runnable {}", runnable);

runnable.run();

return;

}

List threadRunnables = RUNNABLES.get();

if (threadRunnables == null) {

threadRunnables = new ArrayList();

RUNNABLES.set(threadRunnables);

TransactionSynchronizationManager.registerSynchronization(this);

}

threadRunnables.add(runnable);

}

@Override

public void afterCommit() {

List threadRunnables = RUNNABLES.get();

LOGGER.info("Transaction successfully committed, executing {} runnables", threadRunnables.size());

for (int i = 0; i < threadRunnables.size(); i++) {

Runnable runnable = threadRunnables.get(i);

LOGGER.info("Executing runnable {}", runnable);

try {

threadPool.execute(runnable);

} catch (RuntimeException e) {

LOGGER.error("Failed to execute runnable " + runnable, e);

}

}

}

@Override

public void afterCompletion(int status) {

LOGGER.info("Transaction completed with status {}", status == STATUS_COMMITTED ? "COMMITTED" : "ROLLED_BACK");

RUNNABLES.remove();

}

}

调用：

@Service

@Trasaction

public class MyService {

@Autowired

private AfterCommitExecutor afterCommitExecutorImpl;

public void test() {

//TODO 业务功能

//事务提交后执行

afterCommitExecutor.execute(new Runnable() {

@Override

public void run() {

//TODO 事务提交后功能

}

});

}

}