forkcontinuation.java

一个很好的微工作流内核

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

package com.microworkflow.execution;

import java.util.Iterator;

import com.microworkflow.process.WorkflowContext;

public class ForkContinuation extends Continuation {
	protected Iterator branches;

	public ForkContinuation(Continuation continuation) {
		super(continuation, continuation.getWorkflow());
	}
	
	public Continuation applyContinuationIn(WorkflowContext context) {
		Continuation branch = this.makeNullContinuation();		
		if (branches.hasNext()) {
			branch = (Continuation) branches.next();
		}
		while (branches.hasNext()) {
			Continuation otherBranch = (Continuation) branches.next();
			getWorkflow().addContinuation(otherBranch);
		}
		resetState();
		return branch.applyContinuationIn(context);
	}
	
	public void setBranches(Iterator branches) {
		this.branches = branches;
	}
	
}