TestUtils.java

package de.tum.cit.ase.ares.api;

import java.util.concurrent.Callable;
import java.util.function.*;

import org.apiguardian.api.API;
import org.apiguardian.api.API.Status;

import de.tum.cit.ase.ares.api.internal.*;

/**
 * Utilities for writing tests with Ares in the form of static methods.
 *
 * @author Christian Femers
 */
@API(status = Status.MAINTAINED)
public final class TestUtils {

	private TestUtils() {
	}

	public static void invokeBlacklisted(Runnable action) {
		BlacklistedInvoker.invoke(action);
	}

	public static <T, R> R invokeBlacklisted(T t, Function<T, R> action) {
		return BlacklistedInvoker.invoke(t, action);
	}

	public static <T> void invokeBlacklisted(T t, Consumer<T> action) {
		BlacklistedInvoker.invoke(t, action);
	}

	public static <R> R invokeBlacklisted(Supplier<R> action) {
		return BlacklistedInvoker.invoke(action);
	}

	public static <R> R invokeCheckedBlacklisted(Callable<R> action) throws Exception {
		return BlacklistedInvoker.invokeChecked(action);
	}

	public static void privilegedThrow(Runnable possiblyThrowingAction) {
		try {
			possiblyThrowingAction.run();
		} catch (Throwable t) {
			throw new PrivilegedException(t);
		}
	}

	public static <R> R privilegedThrow(Callable<R> possiblyThrowingAction) throws Exception {
		try {
			return possiblyThrowingAction.call();
		} catch (Throwable t) {
			throw new PrivilegedException(t);
		}
	}

	public static void privilegedFail(String message) {
		throw new PrivilegedException(new AssertionError(message));
	}

	public static ThreadGroup getRootThreadGroup() {
		ThreadGroup group = Thread.currentThread().getThreadGroup();
		for (ThreadGroup tg = group; tg != null; tg = group.getParent()) {
			group = tg;
		}
		return group;
	}
}