libgrape-lite
A C++ library for parallel graph processing
Public Member Functions | Private Attributes | List of all members
grape::MessageBufferPool Class Reference

Public Member Functions

void init (size_t size, size_t chunk)
 
MessageBuffer take (size_t expect_chunk)
 
MessageBuffer take_default ()
 
void give (MessageBuffer &&buf)
 
size_t chunk_size () const
 

Private Attributes

SpinLock lock_
 
std::deque< MessageBufferque_
 
size_t init_size_
 
size_t chunk_size_
 
size_t used_size_
 
size_t peak_used_size_
 
size_t extra_used_size_
 
size_t peak_extra_used_size_