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;
+}