Examples of Promise

com.amazonaws.services.simpleworkflow.flow.core.Promise
Promise is a future like object that is used as a placeholder for a result of an asynchronous API. Java Future is a synchronization construct that is used to block a thread that called get() method if result is not available yet. Promise differs from it as it cannot be used for blocking. A call to its get() method throws IllegalStateException if result is not available yet. The correct way to ensure that Promise is ready is to access it from a method that is annotated as @Asynchronous and have the given Promise as one its arguments or from {@link Task#doExecute()} method assuming that promise waspassed to the Task as a constructor parameter.
Promise is not linked to error handling like Future is. In case of exceptions they are propagated to the {@link TryCatchFinally#doCatch(Throwable)} methodof the {@link TryCatchFinally} that owns the asynchronous task that failed.See {@link TryCatchFinally} for more info on the error handling.
For promises that don't need a value and just used to ensure correct ordering of asynchronous operations the common pattern to use {@link Void} as ageneric type.
@param < V> The result type returned by this Promise's get method. Use {@link Void} to represent Promise that indicates completion ofoperation that doesn't return a value.
com.google.gwt.query.client.Promise
Definition of jquery Promise interface used in gquery.
com.sleepycat.je.rep.elections.Protocol.Promise
com.twitter.util.Promise
org.fusesource.mqtt.client.Promise
irino.com">Hiram Chirino
org.jgroups.util.Promise
Allows a thread to submit an asynchronous request and to wait for the result. The caller may choose to check for the result at a later time, or immediately and it may block or not. Both the caller and responder have to know the promise. @author Bela Ban @version $Id: Promise.java,v 1.14 2007/11/19 13:55:57 belaban Exp $
spullara.util.concurrent.Promise

Examples of org.jgroups.util.Promise

     * pbcast.NAKACK bug, which used to leave pbcast.NAKACK in a broken state
     * after DISCONNECT. Because of this problem, the channel couldn't be used
     * to multicast messages.
     **/
    public void testDisconnectConnectSendTwo_Default() throws Exception {
        final Promise msgPromise=new Promise();
        JChannel coordinator=new JChannel();
        coordinator.setReceiver(new PromisedMessageListener(msgPromise));
        coordinator.connect("testgroup");


        channel=new JChannel();
        channel.connect("testgroup1");
        channel.disconnect();
        channel.connect("testgroup");


        channel.send(new Message(null, null, "payload"));


        Message msg=(Message)msgPromise.getResult(20000);
        assertNotNull(msg);
        assertEquals("payload", msg.getObject());


        coordinator.close();
    }

View Full Code Here

Examples of org.jgroups.util.Promise

     public void testDisconnectConnectSendTwo_TUNNEL() throws Exception {
        GossipRouter router=null;
        try {
            router=new GossipRouter();
            router.start();
            final Promise msgPromise=new Promise();
            JChannel coordinator=createChannel();
            setProps(coordinator);
            coordinator.setReceiver(new PromisedMessageListener(msgPromise));
            coordinator.connect("testgroup");


            channel=createChannel();
            setProps(channel);
            channel.connect("testgroup1");
            channel.disconnect();
            channel.connect("testgroup");


            channel.send(new Message(null, null, "payload"));


            Message msg=(Message)msgPromise.getResult(20000);
            assertNotNull(msg);
            assertEquals("payload", msg.getObject());
            channel.close();
            coordinator.close();
        }

View Full Code Here

Examples of org.jgroups.util.Promise

     * bug, which used to leave pbcast.NAKACK in a broken state after
     * DISCONNECT. Because of this problem, the channel couldn't be used to
     * multicast messages.
     **/
    public void testDisconnectConnectSendTwo() throws Exception {
        final Promise msgPromise=new Promise();
        Channel coordinator=createChannel("A");
        coordinator.connect("testgroup");
        PullPushAdapter ppa=
                new PullPushAdapter(coordinator,
                                    new PromisedMessageListener(msgPromise));
        ppa.start();


        channel=createChannel("A");
        channel.connect("testgroup1");
        channel.disconnect();
        channel.connect("testgroup");
        channel.send(new Message(null, null, "payload"));
        Message msg=(Message)msgPromise.getResult(20000);
        assertTrue(msg != null);
        assertEquals("payload", msg.getObject());
        ppa.stop();
        coordinator.close();
        channel.close();

View Full Code Here

Examples of org.jgroups.util.Promise

        super(name);
    }


    public void setUp() throws Exception {
        super.setUp();
        promise=new Promise();
        router=new GossipRouter();
        router.start();
    }

View Full Code Here

Examples of org.jgroups.util.Promise

        super(name);
    }


    public void setUp() throws Exception {
        super.setUp();
        p=new Promise();
    }

View Full Code Here

Examples of org.jgroups.util.Promise

        assertTrue(future.isDone());
    }




    public void testImmediateExecution() {
        Promise p=new Promise();
        ImmediateTask task=new ImmediateTask(p);
        timer.execute(task);
        try {
            long start=System.currentTimeMillis(), stop;
            p.getResultWithTimeout(5);
            stop=System.currentTimeMillis();
            System.out.println("task took " + (stop-start) + "ms");
        }
        catch(TimeoutException e) {
            fail("ran into timeout - task should have executed immediately");

View Full Code Here

Examples of org.jgroups.util.Promise

        if(stopped == false) return;






        if(start_promise == null)
            start_promise=new Promise();
        else
            start_promise.reset();


        down(new Event(Event.START));
        start_result=start_promise.getResult(0);

View Full Code Here

Examples of org.jgroups.util.Promise

     */
    public void stopStack() {
        if(stopped) return;


        if(stop_promise == null)
            stop_promise=new Promise();
        else
            stop_promise.reset();


        down(new Event(Event.STOP));
        stop_promise.getResult(5000);

View Full Code Here

Examples of org.jgroups.util.Promise


    public boolean setProperties(Properties props) {
        super.setProperties(props);


        use_flush=Util.parseBoolean(props, "use_flush", false);        
        flush_promise=new Promise();
        
        flush_timeout = Util.parseLong(props, "flush_timeout", flush_timeout);       
        if(props.size() > 0) {
            log.error("the following properties are not recognized: " + props);
            return false;

View Full Code Here

Examples of org.jgroups.util.Promise

        p.setResult(22);
        assert p.getResult() == 22;
    }


    public static void testGetResultNoTimeout() {
        final Promise p=new Promise();
        Object result;
        new ResultSetter(p, 500).start();
        result=p.getResult(0);
        Assert.assertEquals(Boolean.TRUE, result);
    }

View Full Code Here

0 1 2 3 4

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.