多个连接的雄辩的回滚事务

import time

class Coordinator:
    def __init__(self):
        self.participants = []

    def add_participant(self, participant):
        self.participants.append(participant)

    def prepare_phase(self):
        for participant in self.participants:
            if not participant.prepare():
                return False
        return True

    def commit_phase(self):
        for participant in self.participants:
            participant.commit()

    def rollback_phase(self):
        for participant in self.participants:
            participant.rollback()

class Participant:
    def __init__(self, name):
        self.name = name
        self.prepared = False

    def prepare(self):
        print(f"{self.name} is preparing...")
        time.sleep(1)
        self.prepared = True
        return True

    def commit(self):
        if self.prepared:
            print(f"{self.name} is committing...")
        else:
            print(f"{self.name} cannot commit, not prepared.")

    def rollback(self):
        if self.prepared:
            print(f"{self.name} is rolling back...")
            self.prepared = False
        else:
            print(f"{self.name} cannot rollback, not prepared.")

# 示例使用
coordinator = Coordinator()
participant1 = Participant("Participant 1")
participant2 = Participant("Participant 2")

coordinator.add_participant(participant1)
coordinator.add_participant(participant2)

if coordinator.prepare_phase():
    coordinator.commit_phase()
else:
    coordinator.rollback_phase()