MultiThreadHashTable.h

Go to the documentation of this file.

 
#ifndef _JOINALGO_NPJ_MULTITHREADHASHTABLE_H_
#define _JOINALGO_NPJ_MULTITHREADHASHTABLE_H_
#include <Common/Tuples.h>
#include <stdint.h>
#include <memory>
#include <condition_variable>
#include <mutex>
#include <vector>
namespace OoOJoin {
 
#define  BUCKET_SIZE 4
class MtBucket;
typedef std::shared_ptr<MtBucket> MtBucketPtr;
//typedef vector<TuplePtr> NPJTuplePtr;
typedef TrackTuplePtr NPJTuplePtr;
//template <class cell_t>
class MtBucket {
 private:
  std::mutex m_mut;
  //vector<NPJTuplePtr>tuples;
  TrackTuplePtr tuples[BUCKET_SIZE];
  MtBucketPtr next = nullptr;
  size_t count = 0;
 public:
  /*MtBucket(){
  }
  ~MtBucket(){}*/
  void lock() {
    while (!m_mut.try_lock());
  }
  void unlock() {
    m_mut.unlock();
  }
  void duplicatedInsert(NPJTuplePtr tp);
  size_t probeTuple(NPJTuplePtr tp);
  /*MtBucketPtr getNext(){
    return next;
  }*/
};
class MultiThreadHashTable {
 private:
 
 public:
  keyType hash_mask;
  keyType skip_bits;
  std::vector<MtBucket> buckets;
  MultiThreadHashTable() {}
  MultiThreadHashTable(size_t bks);
  ~MultiThreadHashTable() {}
  void buildTable(NPJTuplePtr *tps, size_t len);
  size_t probeTuple(NPJTuplePtr tp);
 
};
typedef std::shared_ptr<MultiThreadHashTable> MultiThreadHashTablePtr;
}
#endif //ALIANCEDB_INCLUDE_JOINALGO_NPJ_MULTITHREADHASHTABLE_H_