com.yomahub.liteflow.slot

Class DataBus

java.lang.Object

com.yomahub.liteflow.slot.DataBus

public class DataBus
extends Object

数据BUS，主要用来管理Slot，用以分配和回收

Author:

Bryan.Zhang

Field Summary

Fields

Modifier and Type	Field and Description
static AtomicInteger	OCCUPY_COUNT

Constructor Summary

Constructors

Constructor and Description
DataBus()

Method Summary

Modifier and Type	Method and Description
static List<cn.hutool.core.lang.Tuple>	getContextBeanList(int slotIndex)
static Slot	getSlot(int slotIndex)
static void	init() 这里原先版本中是static块，现在改成init静态方法，由FlowExecutor中的init去调用 这样的改动对项目来说没有什么实际意义，但是在单元测试中，却有意义。
static int	offerSlotByBean(List<Object> contextList)
static int	offerSlotByClass(List<Class<?>> contextClazzList)
static void	releaseSlot(int slotIndex)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

OCCUPY_COUNT

public static AtomicInteger OCCUPY_COUNT

Constructor Detail

DataBus

public DataBus()

Method Detail

init

public static void init()

这里原先版本中是static块，现在改成init静态方法，由FlowExecutor中的init去调用 这样的改动对项目来说没有什么实际意义，但是在单元测试中，却有意义。 因为单元测试中所有的一起跑，jvm是不退出的，所以如果是static块的话，跑多个testsuite只会执行一次。 而由FlowExecutor中的init去调用，是会被执行多次的。保证了每个单元测试都能初始化一遍

offerSlotByClass

public static int offerSlotByClass(List<Class<?>> contextClazzList)

offerSlotByBean

public static int offerSlotByBean(List<Object> contextList)

getSlot

public static Slot getSlot(int slotIndex)

getContextBeanList

public static List<cn.hutool.core.lang.Tuple> getContextBeanList(int slotIndex)

releaseSlot

public static void releaseSlot(int slotIndex)