actor

A java actor library with linked and priority queue support.

To produce a jar file simply run ant.

package com.benbria.actor;

public class ActorExample {
    public static void main(String[] args) throws InterruptedException {
        Actor<String> actor = ThreadActor.spawn(new Behaviour<String>() {
            @Override
            public boolean receive(Actor<String> self, String msg) {
                System.out.println("Got: " + msg);
                return !msg.equals("stop");
            }

            @Override
            public void exception(Actor<String> self, Exception e) {}
        });

        actor.send("hello");
        actor.send("world");
        Thread.sleep(1000);
        actor.send("stop");
    }
}

Output:

Got: hello
Got: world

License

MIT