run方法里調service方法。

ExecutorService executorService = Executors.newSingleThreadExecutor();
Future<Object> future = executorService.submit(new Callable<Object>() {
    @Override
    public Object call() throws Exception {
        // return results
        return null;
    }
});
// get results
future.get();

通過concurrent并發(fā)編程中的api可以拿到線程的返回值。

final Lock lock = new ReentrantLock();
final Condition condition = lock.newCondition();
final AtomicReference<Object> results = new AtomicReference<>();
Thread t = new Thread() {

    @Override
    public void run() {
        try {
            Thread.sleep(500);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        lock.lock();
        // set results
        results.set("success");
        condition.signalAll();
        lock.unlock();
    }
};
t.start();

lock.lock();
condition.await();
// get results
System.out.println(results.get());
lock.unlock();

普通線程也可以使用上述方式模擬線程的返回值，來決定事務的commit/rollback。