jbpm5.1介绍（5）

public class LoopingExample {

    public static final void main(String[] args) {

        try {

            // load up the knowledge base

            KnowledgeBase kbase = readKnowledgeBase();

            StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();

            KnowledgeRuntimeLogger logger = KnowledgeRuntimeLoggerFactory.newThreadedFileLogger(ksession, "test", 1000);

            // start a new process instance

            Map<String, Object> params = new HashMap<String, Object>();

            params.put("count", 10);

            ksession.startProcess("com.sample.looping", params);

            logger.close();

        } catch (Throwable t) {

            t.printStackTrace();

        }

    }

    private static KnowledgeBase readKnowledgeBase() throws Exception {

        KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();

        kbuilder.add(ResourceFactory.newClassPathResource("looping/Looping.bpmn"), ResourceType.BPMN2);

        return kbuilder.newKnowledgeBase();

    }

}

i = 0

i = 1

i = 2

i = 3

i = 4

i = 5

i = 6

i = 7

i = 8

i = 9

Loop completed

public class MultipleInstanceExample {

    public static final void main(String[] args) {

        try {

            // load up the knowledge base

            KnowledgeBase kbase = readKnowledgeBase();

            StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();

            KnowledgeRuntimeLogger logger = KnowledgeRuntimeLoggerFactory.newThreadedFileLogger(ksession, "test", 1000);

            ksession.getWorkItemManager().registerWorkItemHandler("Human Task", new WSHumanTaskHandler());

            // start a new process instance

            Map<String, Object> params = new HashMap<String, Object>();

            <span style="color: #ff0000;">List<String> list = new ArrayList<String>();

            list.add("krisv");

            list.add("john doe");

            list.add("superman");

            params.put("list", list);

</span>         ksession.startProcess("com.sample.multipleinstance", params);

            logger.close();

        } catch (Throwable t) {

            t.printStackTrace();

        }

    }

    private static KnowledgeBase readKnowledgeBase() throws Exception {

        KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();

        kbuilder.add(ResourceFactory.newClassPathResource("multipleinstance/multipleinstance.bpmn"), ResourceType.BPMN2);

        return kbuilder.newKnowledgeBase();

    }

}