INNER CODE UNIT · Java

commit

jwpttcg66/redis-game-transaction · src/main/java/com/redis/transaction/GameTransaction.java:26

    public void commit() throws GameTransactionException {
        if(state != TRYCOMMITED)
            throw new GameTransactionException();
        this.state = COMMITED;
        for(GameTransactionEntityInterface entity:entities){
            if(!entity.needCommit()){
                continue;
            }
            entity.commit();
        }
    }

    public void rollback() throws GameTransactionException {
        //无条件进行回滚
        this.state = ROLLEDBACK;
        for(GameTransactionEntityInterface entity:entities){
            entity.rollback();
        }

View source record →