Add working and non working examples

Author: axmmisaka

src/benchmark/FJCreate.ts

@@ -0,0 +1,84 @@
+/**
+ * Typescript runtime implementation of Fork Join - Create benchmark programme
+ * of Savina benchmark suite.
+ * @author axmmisaka (github.com/axmmisaka)
+ */
+
+import {
+    Log,
+    Reactor,
+    App,
+    type TimeValue,
+    InPort,
+    OutPort
+} from "../core/internal";
+
+Log.global.level = Log.levels.ERROR;
+
+const N = 400;
+
+export class ForkJoinReactor extends Reactor {
+    // private valueToCalculate;
+    triggerPort: InPort<number>;
+    constructor(parent: Reactor, name = "Innocent Reactor") {
+        super(parent, name);
+        this.triggerPort = new InPort(this);
+        this.addReaction(
+            [this.triggerPort],
+            [this.triggerPort],
+            (inp) => {
+                const val = inp.get();
+                if (val == null) {
+                    throw new Error(`inp is absent for ${this._name}`)
+                } 
+                const sint = Math.sin(val);
+                const res = sint * sint;
+                if (res <= 0) {
+                    throw new Error(`this is kinda insane, ${res}`);
+                } else {
+                    console.log(`I am ${this._name}. I finished calculating at time ${this.util.getCurrentLogicalTime()}. Result is ${res}`)
+                }
+            }
+        );
+    }
+}
+
+export class FJCreator extends Reactor {
+    forks: ForkJoinReactor[];
+    outp: OutPort<number>;
+
+    constructor(parent: Reactor) {
+        super(parent, "FJCreator");
+        this.forks = [];
+        this.outp = new OutPort(this);
+        for (let i = 0; i < N; ++i) {
+            this.addMutation(
+                [this.startup],
+                [],
+                () => {
+                    const fork = this._uncheckedAddSibling(ForkJoinReactor, `FJReactor ${i}`);
+                    this.forks.push(fork);
+                    this._connect(this.outp, fork.triggerPort);
+                }
+            )
+        }
+    }
+}
+
+export class FJHost extends App {
+    creator: FJCreator;
+    constructor(
+        name: string,
+        timeout: TimeValue | undefined = undefined,
+        keepAlive = false,
+        fast = false,
+        success?: () => void,
+        fail?: () => void
+    ) {
+        super(timeout, keepAlive, fast, success, fail, name);
+        this.creator = new FJCreator(this);
+    }
+}
+
+const fj = new FJHost("FJ");
+fj._start();

src/benchmark/FJCreateNaive.ts

@@ -0,0 +1,72 @@
+/**
+ * Typescript runtime implementation of Fork Join - Create benchmark programme
+ * of Savina benchmark suite.
+ * @author axmmisaka (github.com/axmmisaka)
+ */
+
+import {
+    Log,
+    Reactor,
+    App,
+    type TimeValue,
+    InPort,
+    OutPort
+} from "../core/internal";
+
+Log.global.level = Log.levels.ERROR;
+
+const N = 400;
+
+export class ForkJoinReactor extends Reactor {
+    // private valueToCalculate;
+    triggerPort: InPort<number>;
+    constructor(parent: Reactor, name = "Innocent Reactor") {
+        super(parent, name);
+        this.triggerPort = new InPort(this);
+        this.addReaction(
+            [this.startup]/* [this.triggerPort] */,
+            [this.triggerPort],
+            (inp) => {
+                const val = 69.420 /* inp.get() */;
+                if (val == null) {
+                    throw new Error(`inp is absent for ${this._name}`)
+                } 
+                const sint = Math.sin(val);
+                const res = sint * sint;
+                if (res <= 0) {
+                    throw new Error(`this is kinda insane, ${res}`);
+                } else {
+                    console.log(`I am ${this._name}. I finished calculating at time ${this.util.getCurrentLogicalTime()}. Result is ${res}`)
+                }
+            }
+        );
+    }
+}
+
+export class FJCreator extends App {
+    forks: ForkJoinReactor[];
+    outp: OutPort<number>;
+
+    constructor(
+        name: string,
+        timeout: TimeValue | undefined = undefined,
+        keepAlive = false,
+        fast = false,
+        success?: () => void,
+        fail?: () => void
+    ) {
+        super(timeout, keepAlive, fast, success, fail, name);
+        this.forks = [];
+        this.outp = new OutPort(this);
+        const key = this._getKey(this.outp);
+        (this.outp.asWritable(key)).set(69.420);
+        for (let i = 0; i < N; ++i) {
+            const fork = this._uncheckedAddChild(ForkJoinReactor, `FJReactor ${i}`);
+            this.forks.push(fork);
+            // this._connect(this.outp, fork.triggerPort);
+        }
+    }
+}
+
+const fj = new FJCreator("FJ");
+fj._start()