[Tutorial] Cycle Based Event Manager

/*
 * CycleController
 *
 * By Fritz (Kataang)
 *
 * Controls all of the cycle events
 */
package server.cycle;

import java.util.ArrayList;
import server.Config;
import server.util.Misc;

public class CycleController implements Runnable {

	public static void add(double cyclesBetweenRunning, double cyclesToRun,
			Cycle cycle) {
		cycles.add(new CycleContainer(cyclesBetweenRunning, cyclesToRun, cycle));
	}

	public static void add(double cyclesToRun, Cycle cycle) {
		cycles.add(new CycleContainer(cyclesToRun, -1, cycle));
	}

	public void run() {
		while (true) {
			for (CycleContainer cycle : cycles) {
				try {
					if (cycle.lastRun + Config.SERVER_CYCLE
							* cycle.cyclesBetweenRunning() <= System
							.currentTimeMillis()
							&& cycle.cyclesToRun() > cycle.cyclesRan) {
						cycle.toDo();
						cycle.cyclesRan++;
					} else if (cycle.cyclesToRun() <= cycle.cyclesRan) {
						toRemove.add(cycle);
					}
				} catch (Exception e) {
					Misc.print("Error during cycle, stopping the cycle.");
				}
			}
			for (CycleContainer cycle : toRemove) {
				cycles.remove(cycle);
			}
			toRemove.clear();
		}
	}

	private static ArrayList<CycleContainer> cycles = new ArrayList<CycleContainer>();
	private ArrayList<CycleContainer> toRemove = new ArrayList<CycleContainer>();
}

/*
 * CycleContainer
 *
 * By Fritz (Kataang)
 *
 * Contains a cycle
 */
package server.cycle;

import server.util.Misc;

public class CycleContainer {

	public CycleContainer(double cyclesBetweenRunning, double cyclesToRun,
			Cycle cycle) {
		this.cycle = cycle;
		this.cyclesBetweenRunning = cyclesBetweenRunning;
		this.cyclesToRun = cyclesToRun;
		if (cyclesToRun > 0)
			cyclesRan = 0;
		lastRun = System.currentTimeMillis();
	}

	public void toDo() {
		this.lastRun = System.currentTimeMillis();
		cycle.toDo(this);
	}

	public void end(Cycle cycle) {
		cyclesRan = cyclesToRun;
	}

	public double lastRun() {
		return lastRun;
	}

	public double cyclesToRun() {
		return cyclesToRun;
	}

	public double cyclesBetweenRunning() {
		return cyclesBetweenRunning;
	}

	private Cycle cycle;
	private double cyclesToRun, cyclesBetweenRunning;
	public double cyclesRan = Double.MIN_VALUE, lastRun;
}

/*
 * Cycle
 *
 * By Fritz (Kataang)
 *
 * Interface for a cycle
 */
package server.cycle;

public interface Cycle {
	public void toDo(CycleContainer cycleContainer);
}

Connection.initialize();

new Thread(new CycleController()).start();

public static final double SERVER_CYCLE = 600;

		CycleController.add(4, 10, new Cycle() {
			public void toDo(CycleContainer con) {
				sendMessage("Hey there!");
			}
		});

		CycleController.add(4, 10, new Cycle() {

			public void toDo(CycleContainer con) {
				sendMessage("Hey there!");
			}

		CycleController.add(4, new Cycle() {
			public void toDo(CycleContainer con) {
				sendMessage("Hey there!");
			}
		});

		CycleController.add(4, new Cycle() {

			public void toDo(CycleContainer con) {
				sendMessage("Hey there!");
			}

con.end();