一个工作流引擎脚本语言底层模型及实现

为了支持能够并发执行任意复杂度的拓扑结构的工作流，

可以设计一种脚本语言，其可以非阻塞的形式并发执行任务。

如何在单线程执行脚本中实现并发任务执行模型呢？

我们可以参考类似微软的函数 WaitForMultipleObjects，我们开启任务的时候可以异步的执行它，在脚本中不阻塞。

而可以阻塞在脚本语言的wait函数上，当某个任务完成后，放开阻塞，控制权交由脚本，可以判断具体完成的任务，来决定之后触发的工作流。

下面请看一段lua代码：

	create_task("t1",1);
	create_task("t2",2);
	create_task("t3",3);
	create_task("t4",4);
	
	start_task("t1");
	start_task("t2");
	
	local alltasks = {"t1","t2"}
	
	while true do
		t=wait_for_multiple_tasks(alltasks,false)
		for i=1,table.getn(alltasks) do
			if alltasks[i]==t then
				table.remove(alltasks,i)
				break
			end
		end
		if t=="t1" then
			table.insert(alltasks,"t3")
			start_task("t3")
		end
		if t=="t2" then
			table.insert(alltasks,"t4")
			start_task("t4")
		end
		
		if table.getn(alltasks)==0 then break end
	end
	debug("finished")

创建4个任务，同时开始T1、T2，当T1完成时执行T3，T2完成时执行T4，全部执行完之后打印finished

当然，这只是一个模型示例，并非我们最终脚本的形式。

那么，其实基于这个模型，我们就可以实现任意复杂的工作流形式了。