Examples of NonBlockingReactor

org.agilewiki.jactor2.core.reactors.NonBlockingReactor
Process requests/responses quickly and without blocking the thread.
Requests/responses are processed one at a time in the order received, except that requests/responses from the same reactor are given preference.

Requests/responses destined to a different reactor are held until all incoming messages have been processed.

Examples of org.agilewiki.jactor2.core.reactors.NonBlockingReactor

public class TSSMTransactionTest extends CallTestBase {
    public void testI() throws Exception {
        new Plant();
        try {
            final TSSMReference<String> propertiesReference = new TSSMReference<String>();
            final CommonReactor reactor = new NonBlockingReactor();


            final RequestBus<TSSMChanges<String>> validationBus = propertiesReference.validationBus;
            call(new SubscribeAOp<TSSMChanges<String>>(validationBus,
                    reactor) {
                @Override

View Full Code Here

Examples of org.agilewiki.jactor2.core.reactors.NonBlockingReactor

        this(new TSSMap<VALUE>(_sortedMap), _parentReactor);
    }


    private TSSMReference(TSSMap<VALUE> _tssMap) throws Exception {
        super(_tssMap);
        final NonBlockingReactor parentReactor = (NonBlockingReactor) getReactor()
                .getParentReactor();
        validationBus = new RequestBus<TSSMChanges<VALUE>>(parentReactor);
        changeBus = new RequestBus<TSSMChanges<VALUE>>(parentReactor);
    }

View Full Code Here

Examples of org.agilewiki.jactor2.core.reactors.NonBlockingReactor

        changeBus = new RequestBus<TSSMChanges<VALUE>>(parentReactor);
    }


    private TSSMReference(TSSMap<VALUE> _tssMap, IsolationReactor _reactor) throws Exception {
        super(_tssMap, _reactor);
        final NonBlockingReactor parentReactor = (NonBlockingReactor) getReactor()
                .getParentReactor();
        validationBus = new RequestBus<TSSMChanges<VALUE>>(parentReactor);
        changeBus = new RequestBus<TSSMChanges<VALUE>>(parentReactor);
    }

View Full Code Here

Examples of org.agilewiki.jactor2.core.reactors.NonBlockingReactor


    public void testReactor() throws Exception {
        System.out.println("R");
        new Plant();
        try {
            final Reactor reactor = new NonBlockingReactor();


            final MyCloseable mac1 = new MyCloseable();
            final MyCloseable mac2 = new MyCloseable();
            final MyCloseable mac3 = new MyCloseable();
            final MyCloseable mac4 = new MyCloseable();
            final MyFailedCloseable mfac = new MyFailedCloseable();
            reactor.addCloseable(mac1);
            reactor.addCloseable(mac2);
            reactor.addCloseable(mac3);
            reactor.addCloseable(mac4);
            reactor.addCloseable(mfac);
            reactor.removeCloseable(mac4);


            reactor.close();


            assertEquals(mac1.closed, 1);
            assertEquals(mac2.closed, 1);
            assertEquals(mac3.closed, 1);
            assertEquals(mac4.closed, 0);

View Full Code Here

Examples of org.agilewiki.jactor2.core.reactors.NonBlockingReactor

public class NonBlockingBladeBase extends BladeBase implements NonBlockingBlade {
    /**
     * Create a non-blocking blade and a non-blocking reactor whose parent is the internal reactor of Plant.
     */
    public NonBlockingBladeBase() throws Exception {
        _initialize(new NonBlockingReactor());
    }

View Full Code Here

Examples of org.agilewiki.jactor2.core.reactors.NonBlockingReactor

import org.agilewiki.jactor2.core.requests.SOp;
import org.agilewiki.jactor2.core.requests.impl.RequestImpl;


class Hanger extends NonBlockingBladeBase {
    Hanger() throws Exception {
        super(new NonBlockingReactor());
    }

View Full Code Here

Examples of org.agilewiki.jactor2.core.reactors.NonBlockingReactor

    }


    static public void main(final String[] _args) throws Exception {
        new Plant();
        try {
            new OneRuntime().new OneWaySOp("direct", new NonBlockingReactor()).signal();
            new OneWayError().new IndirectAOp("indirect", new NonBlockingReactor()).call();
            System.out.println("ok");
        } finally {
            Plant.close();
        }
    }

View Full Code Here

0 1

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.