NPJ.h

Go to the documentation of this file.

 
//
// Created by tony on 04/03/22.
//
 
#ifndef _JOINALGO_NPJ_NPJ_H_
#define _JOINALGO_NPJ_NPJ_H_
#include <JoinAlgos/NPJ/MultiThreadHashTable.h>
#include <Utils/AbstractC20Thread.hpp>
#include <barrier>
#include <JoinAlgos/AbstractJoinAlgo.h>
namespace OoOJoin {
class NPJ_thread : public AbstractC20Thread {
 private:
  NPJTuplePtr *ts, *tr;
  size_t sLen = 0, rLen = 0;
  int cpu = -1;
  MultiThreadHashTablePtr table = nullptr;
  size_t result = 0;
  BarrierPtr buildBar = nullptr;
  std::shared_ptr<std::thread> threadPtr;
  struct timeval timeBaseStruct;
  //tsType timeStep = 1;
 protected:
  void inlineMain();
 public:
  NPJ_thread() {};
  ~NPJ_thread() {};
 
  void syncTimeStruct(struct timeval tv) {
    timeBaseStruct = tv;
  }
  /*void setTimeStep(tsType _timeStep) {
    timeStep = _timeStep;
  }*/
  void init(NPJTuplePtr *_ts,
            NPJTuplePtr *_tr,
            size_t _sLen,
            size_t _rLen,
            int _cpu,
            MultiThreadHashTablePtr _table,
            BarrierPtr bar) {
    ts = _ts;
    tr = _tr;
    sLen = _sLen;
    rLen = _rLen;
    cpu = _cpu;
    table = _table;
    buildBar = bar;
  }
 
  size_t getResult() {
    return result;
  }
  void waitBuildBar(void) {
    if (buildBar) {
      buildBar->arrive_and_wait();
    }
  }
};
 
class NPJ : public AbstractJoinAlgo {
 
 private:
  std::vector<NPJ_thread> workers;
 public:
  NPJ() {
    setAlgoName("NPJ");
  }
  ~NPJ() {}
  virtual size_t join(C20Buffer<OoOJoin::TrackTuplePtr> windS,
                      C20Buffer<OoOJoin::TrackTuplePtr> windR,
                      int threads = 1);
 
};
typedef std::shared_ptr<NPJ> NPJPtr;
#define  newNPJ std::make_shared<NPJ>
 
class NPJSingle : public AbstractJoinAlgo {
 
 private:
 
 public:
  NPJSingle() {
    setAlgoName("NPJSingle");
  }
  ~NPJSingle() {}
  virtual size_t join(C20Buffer<OoOJoin::TrackTuplePtr> windS,
                      C20Buffer<OoOJoin::TrackTuplePtr> windR,
                      int threads = 1);
 
};
typedef std::shared_ptr<NPJSingle> NPJSinglePtr;
#define  newNPJSingle std::make_shared<NPJSingle>
/***
 * @}
 */
}
#endif //ALIANCEDB_INCLUDE_JOINALGO_NPJ_NPJ_H_