Remove redundant code from AbstractXPUScatterDev

src/core/scatter_devices/abstract_xpu_scatter_device.cpp

@@ -13,7 +13,6 @@ derived.
 #include <boost/lexical_cast.hpp>
 
 #include <fftw3.h>
-#include <taskflow/core/executor.hpp>
 
 #include "abstract_xpu_scatter_device.hpp"
 
@@ -41,7 +40,6 @@ AbstractXPUScatterDevice::AbstractXPUScatterDevice(
     , atfinal_(nullptr)
     , afinal_(0)
     , a2final_(0)
-    , flow_("abstract-scatter-flow")
 {
     // TODO: check ownership semantics and see if shared_ptr really needed
     p_hdf5writer_ =
@@ -162,15 +160,6 @@ void AbstractXPUScatterDevice::runner()
 
     Timer &timer = timer_[boost::this_thread::get_id()];
 
-
-    // Create executor, spawn threads etc.
-    // tf::Executor executor;
-    // auto f = create_flow();
-    // tf::Future<void> fu = executor.run(f);
-    // fu.wait();
-
-    // TODO: implement taskflow
-
     size_t samplingfactor = Params::Inst()->limits.services.monitor.sampling;
     if (samplingfactor == 0) {
         samplingfactor = allcomm_.size() / 20;

src/core/scatter_devices/abstract_xpu_scatter_device.hpp

@@ -37,8 +37,6 @@ common functionality, e.g. basic control flows.
 class AbstractXPUScatterDevice : public IScatterDevice
 {
 protected:
-    tf::Taskflow flow_;
-
     coor_t *p_coordinates;
 
     boost::mpi::communicator allcomm_;
@@ -54,8 +52,8 @@ protected:
     // number of nodes, number of frames/time-steps , number of atoms
     size_t NN, NF, NA;
 
-    fftw_complex *atfinal_ = nullptr;
     // temporary storage for reduce & write phase
+    fftw_complex *atfinal_ = nullptr;
     std::complex<double> afinal_;
     std::complex<double> a2final_;
 
@@ -70,11 +68,6 @@ protected:
 
     void runner() override;
 
-    virtual tf::Taskflow create_flow()
-    {
-        return {};
-    }
-
     virtual void print_pre_stage_info()
     {
     }