jbpm的调度应用

<xml version="1.0" encoding="UTF-8" ?>
	<process-definition xmlns="" name="yytest">
		<start-state name="start">
			<transition name="" to="a"></transition>
		</start-state>
		<state name="a">
			<timer name='reminder' duedate='5 seconds'
				repeat='3 seconds' />
			<script>
				System.out.println(new Date()+ "----node enter:send mail
				to operator.");
			</script>
			</timer>
			<transition name="" to="end"></transition>
		</state>
		<end-state name="end"></end-state>
	</process-definition>

package com.jeffentest;
 
import org.jbpm.*;
import org.jbpm.graph.def.ProcessDefinition;
import org.jbpm.graph.exe.*;
import org.jbpm.scheduler.impl.Scheduler;
 
public class Jeffentest {
	static JbpmConfiguration jbpmConfiguration = JbpmConfiguration
			.getInstance();
	static ProcessDefinition processDefinition = null;
	static ProcessInstance processInstance = null;
	static Scheduler scheduler = null;
 
	public static void initSchedular() {// 设置Schedular的属性
		scheduler = new Scheduler();
		int interval = 5000;
		scheduler.setInterval(interval);
		int historyMaxSize = 0;
		scheduler.setHistoryMaxSize(historyMaxSize);
		scheduler.start();
	}
 
	public static void destroy() {// 这个例子没用到
		scheduler.stop();
	}
 
	static class MySchedularThread extends Thread {// 实际业务处理线程
		public void run() {
			JbpmContext jbpmContext = jbpmConfiguration.createJbpmContext();
			try {
				long processInstanceId = 1;
				processInstance = jbpmContext
						.loadProcessInstance(processInstanceId);
				Token token = processInstance.getRootToken();
				System.out.println(token.getNode());
				// 一定要运行到有timer生成，触发
				token.signal();
				System.out.println(token.getNode());
				jbpmContext.save(processInstance);
				// 如果这里程序到这里退出的话可以看到jbpm_timer表里有一条数据
				Thread.sleep(30 * 1000);// 为模拟效果，此线程停止30秒
				// 节点跳过，timer结束，jbpm_timer表该数据清空
				token.signal();
				System.out.println(token.getNode());
				jbpmContext.save(processInstance);
			} catch (Exception e) {
				e.printStackTrace();
			} finally {
				jbpmContext.close();
			}
		}
	}
 
	public static void main(String[] args) {
		initSchedular();
		MySchedularThread mst = new MySchedularThread();
		mst.start();
	}
}