Class Transaction

ZezeJava/ZezeJava/src/main/java/Zeze/Transaction/Transaction.java:20–855

import org.jetbrains.annotations.Nullable;

public final class Transaction {
	private static final @NotNull Logger logger = LogManager.getLogger(Transaction.class);
	private static final ThreadLocal<Transaction> threadLocal = new ThreadLocal<>();

	public static @NotNull Transaction create(@NotNull Locks locks) {
		var t = threadLocal.get();
		if (t == null)
			threadLocal.set(t = new Transaction());
		t.locks = locks;
		t.created = true;
		return t;
	}

	public static void destroy() {
		var t = threadLocal.get();
		if (t != null)
			t.reuseTransaction();
	}

	public static @Nullable Transaction getCurrent() {
		var t = threadLocal.get();
		return t != null && t.created ? t : null;
	}

	public static @Nullable Transaction getCurrentVerifyRead(@NotNull Bean bean) {
		return getCurrent();
	}

	public static @NotNull Transaction getCurrentVerifyWrite(@NotNull Bean bean) {
		var t = getCurrent();
		if (t == null)
			throw new IllegalStateException("not in transaction");
		t.verifyRecordForWrite(bean);
		return t;
	}

	private final ArrayList<Lockey> holdLocks = new ArrayList<>(); // 读写锁的话需要一个包装类，用来记录当前维持的是哪个锁。
	private final ArrayList<Procedure> procedureStack = new ArrayList<>(); // 嵌套存储过程栈。
	final ArrayList<Runnable> logActions = new ArrayList<>();
	private final ArrayList<Savepoint> savepoints = new ArrayList<>();
	private final ArrayList<Savepoint.Action> actions = new ArrayList<>();
	private final TreeMap<TableKey, RecordAccessed> accessedRecords = new TreeMap<>();
	private Locks locks;
	private @NotNull TransactionState state = TransactionState.Running;
	private boolean created;
	private boolean alwaysReleaseLockWhenRedo;
	private final ArrayList<Bean> redoBeans = new ArrayList<>();
	private final ArrayList<Runnable> redoActions = new ArrayList<>();
	private @Nullable OnzProcedure onzProcedure;
	final Profiler profiler = new Profiler();
	private final AtomicLong totalTransaction = new AtomicLong();
	private Long tid; // 线程不安全。

	private Transaction() {
	}

	public @NotNull ArrayList<Procedure> getProcedureStack() {
		return procedureStack;