package net.minecraft.util.thread;

public abstract class ReentrantBlockableEventLoop<R extends Runnable> extends BlockableEventLoop<R> {
	private int reentrantCount;

	public ReentrantBlockableEventLoop(final String name, final boolean propagatesCrashes) {
		super(name, propagatesCrashes);
	}

	@Override
	protected boolean scheduleExecutables() {
		return this.runningTask() || super.scheduleExecutables();
	}

	protected boolean runningTask() {
		return this.reentrantCount != 0;
	}

	@Override
	protected void doRunTask(final R task) {
		this.reentrantCount++;

		try {
			super.doRunTask(task);
		} finally {
			this.reentrantCount--;
		}
	}
}