andjoincontinuation.java

一个很好的微工作流内核

/*
 * 	 
 *  Copyright (c) 2002, 2003 Dragos Manolescu ([e-mail])
 * 
 *  See the LICENSE file for licensing information.
 */

package com.microworkflow.execution;

import com.microworkflow.process.Workflow;
import com.microworkflow.process.WorkflowContext;

public class AndJoinContinuation extends JoinContinuation {
	protected int numberOfInputs=0;
	protected int counter;

	public AndJoinContinuation(Continuation c, Workflow w) {
		super(c, w);
	}

	public AndJoinContinuation(Continuation continuation) {
		super(continuation, continuation.getWorkflow());
	}

	public void setNumberOfInputs(int numberOfInputs) {
		this.numberOfInputs = numberOfInputs;
	}

	public Continuation applyContinuationIn(WorkflowContext context) {
		counter = counter + 1;
		if (counter == numberOfInputs) {
			resetState();
			return body;
		}
		else {
			return makeNullContinuation();
		}
	}
	
	public void resetState() {
		super.resetState();
		counter=0;
	}

}