MultiThreadHashTable.h

Go to the documentation of this file.

 
#ifndef _JOINALGO_NPJ_MULTITHREADHASHTABLE_H_
#define _JOINALGO_NPJ_MULTITHREADHASHTABLE_H_
#include "Types.h"
#include <stdint.h>
#include <memory>
#include <condition_variable>
#include <mutex>
namespace INTELLI {
 
#define  BUCKET_SIZE 4
class MtBucket;
typedef std::shared_ptr<MtBucket> MtBucketPtr;
//typedef vector<TuplePtr> MtTuplePtr;
typedef TuplePtr MtTuplePtr;
class MtBucket {
 private:
  std::mutex m_mut;
  //vector<MtTuplePtr>tuples;
  TuplePtr 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(TuplePtr tp);
  size_t probeTuple(TuplePtr tp);
  /*MtBucketPtr getNext(){
    return next;
  }*/
};
class MultiThreadHashTable {
 private:
 
 public:
  uint32_t hash_mask;
  uint32_t skip_bits;
  vector<MtBucket> buckets;
  MultiThreadHashTable() {}
  MultiThreadHashTable(size_t bks);
  ~MultiThreadHashTable() {}
  void buildTable(TuplePtrQueue tps);
  void buildTable(TuplePtr *tps, size_t len);
  size_t probeTuple(TuplePtr tp);
 
};
typedef std::shared_ptr<MultiThreadHashTable> MultiThreadHashTablePtr;
}
#endif //ALIANCEDB_INCLUDE_JOINALGO_NPJ_MULTITHREADHASHTABLE_H_