mairbek

public class LoopingBackwardsBenchmark extends SimpleBenchmark {
    @Param({"2", "20", "2000", "2000000", "20000000", "200000000"})
    private int max;


    public int timeForwards(int reps) {
        int dummy = 0;
        for (int i = 0; i < reps; i++) {
            for (int j = 0; j < max; j++) {
                dummy += j;

mairbek

snippet onurl
        app.${1:type}('${2:url}', (res, req) ->
                ${3:body}
        )

mairbek

root
|-- kernel1
|	|-- input
|	|-- output
|	`-- indicator
|
|-- kernel2
|	|-- input
|	`-- output
|

mairbek

public class ZookeeperCoordinator implements Coordinator {
    private static final Logger LOG = LoggerFactory.getLogger(ZookeeperCoordinator.class);

    private final Zoo zoo;
    private final String root;


    public ZookeeperCoordinator(Zoo zoo, String root) {
        this.zoo = zoo;
        this.root = root;

mairbek

public class KernelNode {
    private ZNode core;
    private ZNode input;
    private ZNode output;

    public boolean isAvailable() {
        return core.hasChild("indicator");
    }

    public void lock() {

mairbek

interface ResultCollector extends TaskCompletedListener {

	Report getReport();

}

mairbek

interface TaskProvider {

	boolean hasTask();

	Task getTask();

}

mairbek

class Master {
	Coordinator coordinator;
	TaskProvider taskProvider;
	ResultCollector resultCollector;

	public void run() {
		while(taskProvider.hasTasks()) {
			Task task = taskProvider.getTask();					
			KernelId kernelId = coordinator.getAvailableKernel();	
			

mairbek

interface Kernel {

	KernelId getId();

	void processTask(Task task, ComputationResultHandler handler);

}

interface ComputationResultHandler {

mairbek

interface TaskCompletedListener {

	void onTaskCompleted(KernelId kernelId, Result result);
}