feat: uplaod new results and benchmarks

Author: domferr

include/py_ff_node.hpp

@@ -5,6 +5,7 @@
 #include <ff/ff.hpp>
 #include <iostream>
 #include "error_macros.hpp"
+#include "py_ff_constant.hpp"
 
 class py_ff_node: public ff::ff_node {
 public:
@@ -58,23 +59,18 @@ class py_ff_node: public ff::ff_node {
         // Release the main GIL
         PyEval_SaveThread();
 
+        // if we have a FastFlow's constant, return it
+        if (PyObject_TypeCheck(py_result, &py_ff_constant_type) != 0) {
+            py_ff_constant_object* _const_result = reinterpret_cast<py_ff_constant_object*>(py_result);
+            return _const_result->ff_const;
+        }
+
+        // map None to GO_ON
         if (py_result == Py_None) {
-            return NULL;
+            return ff::FF_GO_ON;
         }
-        return (void*) py_result;
-    }
 
-    void cleanup() {
-        // Cleanup of objects created
-        Py_DECREF(svc_func);
-        Py_DECREF(node);
-        svc_func = nullptr;
-        node = nullptr;
-        PyEval_SaveThread();
-        /*// cleanup thread state with main interpreter
-        PyThreadState_Clear(tstate);
-        PyThreadState_Delete(tstate);*/
-        tstate = nullptr;
+        return (void*) py_result;
     }
 
     void svc_end() override {
@@ -91,7 +87,16 @@ class py_ff_node: public ff::ff_node {
             }
         }
 
-        cleanup();
+        // Cleanup of objects created
+        Py_DECREF(svc_func);
+        Py_DECREF(node);
+        svc_func = nullptr;
+        node = nullptr;
+        PyEval_SaveThread();
+        /*// cleanup thread state with main interpreter
+        PyThreadState_Clear(tstate);
+        PyThreadState_Delete(tstate);*/
+        tstate = nullptr;
     }
 
 private:

res.txt

@@ -0,0 +1,22 @@
+import argparse
+from concurrent.futures import ThreadPoolExecutor, wait
+import threading
+import time
+import busy_wait
+
+def task():
+    busy_wait.wait(100)
+
+if __name__ == "__main__":
+    parser = argparse.ArgumentParser(description='Process some tasks.')
+    parser.add_argument('--workers', type=int, help='Number of worker threads to use', required=True)
+    args = parser.parse_args()
+    start = time.clock_gettime_ns(time.CLOCK_MONOTONIC)
+
+    with ThreadPoolExecutor(max_workers=args.workers) as exe:
+        # issue tasks to the thread pool
+        futures = [exe.submit(task) for _ in range(64) ]
+        wait(futures)
+
+    end = time.clock_gettime_ns(time.CLOCK_MONOTONIC)
+    print(args.workers, ((end - start)/1000))