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))