| 
    Impala
    
   Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop. 
   | 
 
#include <thrift-thread.h>
Public Member Functions | |
| ThriftThreadFactory (const std::string &group, const std::string &prefix) | |
| virtual boost::shared_ptr < apache::thrift::concurrency::Thread >  | newThread (boost::shared_ptr< apache::thrift::concurrency::Runnable > runnable) const | 
| (From ThreadFactory) - creates a new ThriftThread to run the supplied Runnable.  More... | |
| virtual  apache::thrift::concurrency::Thread::id_t  | getCurrentThreadId () const | 
Private Attributes | |
| std::string | group_ | 
| Group name for the Impala ThreadManager.  More... | |
| std::string | prefix_ | 
| Thread name prefix for the Impala ThreadManager.  More... | |
| int64_t | count_ | 
The ThriftThreadFactory is responsible for creating new ThriftThreads to run server tasks on.
Definition at line 38 of file thrift-thread.h.
      
  | 
  inline | 
Group is the thread group for new threads to be assigned to, and prefix is the per-thread prefix (threads are named "prefix-<count_>-<tid>").
Definition at line 42 of file thrift-thread.h.
      
  | 
  virtual | 
(From ThreadFactory) - returns the current thread ID, i.e. the ID of the executing thread (which may not have been created by this factory).
Definition at line 64 of file thrift-thread.cc.
      
  | 
  virtual | 
(From ThreadFactory) - creates a new ThriftThread to run the supplied Runnable.
Definition at line 44 of file thrift-thread.cc.
References count_, group_, impala::name, and prefix_.
      
  | 
  mutableprivate | 
Marked mutable because we want to increment it inside newThread, which for some reason is const.
Definition at line 62 of file thrift-thread.h.
Referenced by newThread().
      
  | 
  private | 
Group name for the Impala ThreadManager.
Definition at line 55 of file thrift-thread.h.
Referenced by newThread().
      
  | 
  private | 
Thread name prefix for the Impala ThreadManager.
Definition at line 58 of file thrift-thread.h.
Referenced by newThread().