feat: more benchmarks

Author: domferr

Dockerfile

@@ -1,13 +1,11 @@
 FROM ubuntu:23.10 
 
 RUN apt-get update
-RUN apt-get -y install python3.12 python3.12-venv python3.12-dev cmake build-essential cmake build-essential valgrind python3.12-dbg
+RUN apt-get -y install python3.12 python3.12-venv python3.12-dev build-essential
 
 WORKDIR app
 
 COPY . .
 
 RUN python3.12 -m venv .venv
-
-#RUN source .venv/bin/activate && pip install setuptools
-#RUN source .venv/bin/activate && python3 setup.py install
+#RUN source .venv/bin/activate && python3.12 -m pip install .

thesis/bench.ipynb

@@ -284,7 +284,7 @@
    "name": "python",
    "nbconvert_exporter": "python",
    "pygments_lexer": "ipython3",
-   "version": "3.11.9"
+   "version": "3.11.4"
   }
  },
  "nbformat": 4,

thesis/bench_many_ms.ipynb

@@ -242,7 +242,7 @@
    "name": "python",
    "nbconvert_exporter": "python",
    "pygments_lexer": "ipython3",
-   "version": "3.11.9"
+   "version": "3.11.4"
   }
  },
  "nbformat": 4,

thesis/comparison.py

@@ -0,0 +1,74 @@
+import multiprocessing
+from fastflow import FFPipeline, ff_send_out
+
+# Stage 1: Generate numbers from 1 to 10
+def number_generator(pipe_out):
+    counter = 1
+    while counter <= 10:
+        pipe_out.send(counter)
+        counter += 1
+    pipe_out.close()
+
+# Stage 2: Square each number
+def square_node(pipe_in, pipe_out):
+    while True:
+        try:
+            data = pipe_in.recv()
+            pipe_out.send(data*data)
+        except EOFError:
+            pipe_out.close()
+            break
+
+# Stage 3: Square each number
+def subtract_five_node(pipe_in, pipe_out):
+    while True:
+        try:
+            data = pipe_in.recv()
+            pipe_out.send(data-5)
+        except EOFError:
+            pipe_out.close()
+            break
+
+# Create the pipes
+pipe1_out, pipe1_in = multiprocessing.Pipe(duplex=False)
+pipe2_out, pipe2_in = multiprocessing.Pipe(duplex=False)
+
+# Create the processes
+processes = [
+    multiprocessing.Process(target=number_generator, args=(pipe1_in)),
+    multiprocessing.Process(target=square_node, args=(pipe1_out, pipe2_in)),
+    multiprocessing.Process(target=subtract_five_node, args=(pipe2_out, None))
+]
+
+# Start all processes in the pipeline
+for process in processes:
+    process.start()
+
+# Wait for all processes to finish
+for process in processes:
+    process.join()
+
+
+class NumberGenerator():
+    def svc(self):
+        for i in range(1, 11):
+            ff_send_out(i)
+        return EOS
+
+class SquareNode():
+    def svc(self, number):
+        return number * number
+
+class SubtractFiveNode():
+    def svc(self, number):
+        return number - 5
+
+# Build the pipeline and add the stages
+pipe = FFPipeline()
+pipe.add_stage(NumberGenerator())
+pipe.add_stage(SquareNode())
+pipe.add_stage(SubtractFiveNode())
+
+# Run the pipeline
+if pipe.run_and_wait_end() < 0:
+    # handle error...

thesis/example.cpp

@@ -0,0 +1,42 @@
+#include <iostream>
+#include <ff/ff.hpp>
+
+// Stage 1: Generate numbers from 1 to 10
+struct NumberGenerator : ff::ff_node_t<int> {
+    int* svc(int*) {
+        for (int i = 1; i <= 10; ++i) {
+            ff_send_out(new int(i));  // Send numbers 1 to 10
+        }
+        return (int*) ff::FF_EOS;  // End of stream
+    }
+};
+
+// Stage 2: Square each number
+struct SquareNode : ff::ff_node_t<int> {
+    int* svc(int* number) {
+        int* result = new int((*number) * (*number));
+        delete number;
+        return result;
+    }
+};
+
+// Stage 3: Subtract 5 from each squared number
+struct SubtractFiveNode : ff::ff_node_t<int> {
+    int* svc(int* squared_number) {
+        int* result = new int((*squared_number) - 5);
+        delete squared_number;
+        return result;
+    }
+};
+
+// Build the pipeline and add the stages
+auto pipe = new ff::ff_pipeline();
+pipe->add_stage(new NumberGenerator());
+pipe->add_stage(new SquareNode());
+pipe->add_stage(new SubtractFiveNode());
+
+// Run the pipeline
+if (pipe->run_and_wait_end() < 0) {
+    /* handle error... */
+    return -1;
+}