RuedigerMoeller

abstract class ByteStream { .. }

class SomeClass { 
    void someMethod() { 
        this.getStream().writeByte(13); // call on interface or abstract class 
    }
    ByteStream getStream() { .. } 
}

// later in code

RuedigerMoeller

public class KontrActorPi {

    public static class PiActor extends Actor<PiActor> {
        public void $calculatePiFor(int start, int nrOfElements, Adder adder) {
            double acc = 0.0;
            for (int i = start * nrOfElements; i <= ((start + 1) * nrOfElements - 1); i++) {
                acc += 4.0 * (1 - (i % 2) * 2) / (2 * i + 1);
            }
            adder.$add(acc);
        }

RuedigerMoeller

exec( () -> {
    try {
        return new Promise(new URL("http://www.google.com").getContent());
    } catch (IOException e) {
        return new Promise(null, e);
    }
}).then( (content, error) -> {
    // handle result
});

RuedigerMoeller

private static void testRun(RLTable<TCRecord> table, TCMutator mutator, ClientActor client) {
    async(
        () -> mutator.$init(table),
        () -> {
            client.$run(table);
            return mutator.$run(table, 1000, null);
        },
        () -> table.$sync(),
        () -> client.$unsubscribe(table),
        () -> client.$checkCorrectness(table)

RuedigerMoeller

public class DisruptorTest2 {

    public static class PiJob {
        public double result;
        public int sliceNr;
        public int numIter;
        public int partionId;

        public void calculatePi() {
            double acc = 0.0;

RuedigerMoeller

public class DisruptorTest {

    public static class PiJob {
        public double result;
        public int sliceNr;
        public int numIter;

        public void calculatePi() {
            double acc = 0.0;
            for (int i = sliceNr * numIter; i <= ((sliceNr + 1) * numIter - 1); i++) {

RuedigerMoeller

public class DisruptorTest {

    public static class PiJob {
        public double result;
        public int sliceNr;
        public int numIter;

        public void calculatePi() {
            double acc = 0.0;
            for (int i = sliceNr * numIter; i <= ((sliceNr + 1) * numIter - 1); i++) {

RuedigerMoeller

public class ActorPiSample {

    public static class PiActor extends Actor {
        public void calculatePiFor(int start, int nrOfElements, ChannelActor result ) {
            double acc = 0.0;
            for (int i = start * nrOfElements; i <= ((start + 1) * nrOfElements - 1); i++) {
                acc += 4.0 * (1 - (i % 2) * 2) / (2 * i + 1);
            }
            result.receiveResult(acc);
        }

RuedigerMoeller

public class ThreadPi {

    static double calculatePiFor(int slice, int nrOfIterations) {
        double acc = 0.0;
        for (int i = slice * nrOfIterations; i <= ((slice + 1) * nrOfIterations - 1); i++) {
            acc += 4.0 * (1 - (i % 2) * 2) / (2 * i + 1);
        }
        return acc;
    }

RuedigerMoeller

static double calculatePiFor(int slice, int nrOfIterations) {
    double acc = 0.0;
    for (int i = slice * nrOfIterations; i <= ((slice + 1) * nrOfIterations - 1); i++) {
        acc += 4.0 * (1 - (i % 2) * 2) / (2 * i + 1);
    }
    return acc;
}