Examples of Parallel

com.consol.citrus.container.Parallel
Test action will execute nested actions in parallel. Each action is executed in a separate thread. Container joins all threads and waiting for them to end successfully. @author Christoph Deppisch
com.impetus.labs.korus.addons.constructs.parallelfor.Parallel
Parallel Construct parallelFor is implemented inside this class. Similar constructs can be implemented by creating classes like these.
com.intel.hadoop.graphbuilder.util.Parallel
Parallel for equivalent implementation. @author Haijie Gu
org.apache.commons.scxml.model.Parallel
The class in this SCXML object model that corresponds to the <parallel> SCXML element, which is a wrapper element to encapsulate parallel state machines. For the <parallel> element to be useful, each of its <state> substates must itself be complex, that is, one with either <state> or <parallel> children.
org.apache.commons.scxml2.model.Parallel
The class in this SCXML object model that corresponds to the <parallel> SCXML element, which is a wrapper element to encapsulate parallel state machines. For the <parallel> element to be useful, each of its <state> substates must itself be complex, that is, one with either <state> or <parallel> children.
org.apache.tools.ant.taskdefs.Parallel
Executes the contained tasks in separate threads, continuing once all are completed.
New behavior allows for the ant script to specify a maximum number of threads that will be executed in parallel. One should be very careful about using the waitFor task when specifying threadCount as it can cause deadlocks if the number of threads is too small or if one of the nested tasks fails to execute completely. The task selection algorithm will insure that the tasks listed before a task have started before that task is started, but it will not insure a successful completion of those tasks or that those tasks will finish first (i.e. it's a classic race condition).
@since Ant 1.4 @ant.task category="control"
org.easetech.easytest.annotation.Parallel
org.jcsp.lang.Parallel

Examples of org.apache.commons.scxml.model.Parallel

                            }
                        }
                    }
                }
            } else if (tt instanceof Parallel) {
                Parallel prl = (Parallel) tt;
                for (Iterator i = prl.getStates().iterator(); i.hasNext();) {
                    //fork
                    wrkSet.addLast(i.next());
                }
            } else if (tt instanceof History) {
                History h = (History) tt;

View Full Code Here

Examples of org.apache.commons.scxml.model.Parallel

            for (int len = 0; len < et.size(); len++) {
                serializeTransition(b, (Transition) et.get(len), indent
                    + INDENT);
            }
        }
        Parallel p = s.getParallel();
        Invoke inv = s.getInvoke();
        if (p != null) {
            serializeParallel(b, p, indent + INDENT);
        } else if (inv != null) {
            serializeInvoke(b , inv, indent + INDENT);

View Full Code Here

Examples of org.apache.commons.scxml.model.Parallel

                //could add next two lines as a Digester rule for Transition
                trn.setParent(s);
                updateTransition(trn, targets);
            }
        }
        Parallel p = s.getParallel();
        Invoke inv = s.getInvoke();
        if ((inv != null && p != null)
                || (inv != null && !c.isEmpty())
                || (p != null && !c.isEmpty())) {
            logAndThrowModelError(ERR_STATE_BAD_CONTENTS,

View Full Code Here

Examples of org.apache.commons.scxml.model.Parallel

        assertTrue(SCXMLHelper.isLegalConfig(states, new SimpleErrorReporter()));
    }
    
    public void testIsLegalConfigInvalidParallel() {
        Set states = new HashSet();
        Parallel parallel = new Parallel();


        Parallel parent = new Parallel();
        parent.setId("4");


        State state1 = new State();
        state1.setId("1");
        State state2 = new State();
        state2.setId("2");
        
        parent.addState(state1);
        parent.addState(state2);
        
        parallel.setParent(parent);
        
        states.add(parallel);

View Full Code Here

Examples of org.apache.commons.scxml.model.Parallel


        SCXML scxml = new SCXML();
        scxml.setVersion("1.0");
        scxml.setInitial("par");


        Parallel par = new Parallel();
        par.setId("par");


        State s1 = new State();
        s1.setId("S1");


        State s11 = new State();
        s11.setId("S11");


        s1.addChild((TransitionTarget)s11);


        State s2 = new State();
        s2.setId("S2");


        State s21 = new State();
        s21.setId("S21");


        s2.addChild((TransitionTarget)s21);


        par.addChild((TransitionTarget)s1);
        par.addChild((TransitionTarget)s2);


        scxml.addChild(par);


        String assertValue = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n"
            + "<scxml xmlns=\"http://www.w3.org/2005/07/scxml\" "

View Full Code Here

Examples of org.apache.commons.scxml.model.Parallel

            for (int len = 0; len < et.size(); len++) {
                serializeTransition(b, (Transition) et.get(len), indent
                    + INDENT);
            }
        }
        Parallel p = s.getParallel();
        Invoke inv = s.getInvoke();
        if (p != null) {
            serializeParallel(b, p, indent + INDENT);
        } else if (inv != null) {
            serializeInvoke(b , inv, indent + INDENT);

View Full Code Here

Examples of org.apache.commons.scxml.model.Parallel

                //could add next two lines as a Digester rule for Transition
                trn.setParent(s);
                updateTransition(trn, targets);
            }
        }
        Parallel p = s.getParallel();
        Invoke inv = s.getInvoke();
        if ((inv != null && p != null)
                || (inv != null && !c.isEmpty())
                || (p != null && !c.isEmpty())) {
            logAndThrowModelError(ERR_STATE_BAD_CONTENTS,

View Full Code Here

Examples of org.apache.commons.scxml.model.Parallel

        for (Iterator i = counts.entrySet().iterator(); i.hasNext();) {
            Map.Entry entry = (Map.Entry) i.next();
            TransitionTarget tt = (TransitionTarget) entry.getKey();
            Set count = (Set) entry.getValue();
            if (tt instanceof Parallel) {
                Parallel p = (Parallel) tt;
                if (count.size() < p.getStates().size()) {
                    errRep.onError(ErrorReporter.ILLEGAL_CONFIG,
                        "Not all AND states active for parallel "
                        + p.getId(), entry);
                    legalConfig = false;
                }
            } else {
                if (count.size() > 1) {
                    errRep.onError(ErrorReporter.ILLEGAL_CONFIG,

View Full Code Here

Examples of org.apache.commons.scxml.model.Parallel

            }
        }
        if (p.isCrossRegion()) {
            for (Iterator regions = p.getRegionsExited().iterator();
                    regions.hasNext();) {
                Parallel par = ((Parallel) ((State) regions.next()).
                    getParent());
                //let's find affected states in sibling regions
                for (Iterator siblings = par.getStates().iterator();
                        siblings.hasNext();) {
                    State s = (State) siblings.next();
                    for (Iterator act = currentStates.iterator();
                            act.hasNext();) {
                        TransitionTarget a = (TransitionTarget) act.next();

View Full Code Here

Examples of org.apache.commons.scxml.model.Parallel

        assertTrue(SCXMLHelper.isLegalConfig(states, new SimpleErrorReporter()));
    }
    
    public void testIsLegalConfigInvalidParallel() {
        Set states = new HashSet();
        Parallel parallel = new Parallel();


        Parallel parent = new Parallel();
        parent.setId("4");


        State state1 = new State();
        state1.setId("1");
        State state2 = new State();
        state2.setId("2");
        
        parent.addState(state1);
        parent.addState(state2);
        
        parallel.setParent(parent);
        
        states.add(parallel);

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.