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 <Common/MultiThreadHashTable.h>
#include <Utils/AbstractC20Thread.h>
#include <barrier>
#include <JoinAlgo/AbstractJoinAlgo.h>
namespace INTELLI {
class NPJ_thread : public AbstractC20Thread {
 private:
  TuplePtr *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;
 protected:
  void inlineMain();
 public:
  NPJ_thread() {};
  ~NPJ_thread() {};
  void init(TuplePtr *_ts,
            TuplePtr *_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:
  vector<NPJ_thread> workers;
 public:
  NPJ() {
    setAlgoName("NPJ");
  }
  ~NPJ() {}
  virtual size_t join(TuplePtrQueue ts, TuplePtrQueue tr, int threads = 1);
  virtual size_t join(TuplePtr *ts, TuplePtr *tr, size_t tsLen, size_t trLen, int threads = 1);
  virtual size_t join(TuplePtr *ts, TuplePtr tr, size_t tsLen, int threads = 1);
 
  virtual size_t join(TuplePtrQueue ts, TuplePtr tr, int threads = 1);
 
};
 
typedef std::shared_ptr<NPJ> NPJPtr;
#define  newNPJ() make_shared<NPJ>()
 
class NPJSingle : public AbstractJoinAlgo {
 
 private:
 
 public:
  NPJSingle() {
    setAlgoName("NPJSingle");
  }
  ~NPJSingle() {}
  virtual size_t join(TuplePtrQueue ts, TuplePtrQueue tr, int threads = 1);
  virtual size_t join(TuplePtr *ts, TuplePtr *tr, size_t tsLen, size_t trLen, int threads = 1);
  virtual size_t join(TuplePtr *ts, TuplePtr tr, size_t tsLen, int threads = 1);
 
  virtual size_t join(TuplePtrQueue ts, TuplePtr tr, int threads = 1);
 
};
 
typedef std::shared_ptr<NPJSingle> NPJSinglePtr;
#define  newNPJSingle() make_shared<NPJSingle>()
/***
 * @}
 */
}
#endif //ALIANCEDB_INCLUDE_JOINALGO_NPJ_NPJ_H_