30 template<
typename Lock>
45 : m_thread_pool(thread_pool), m_stop(false), m_semaphore(max_queue_size) {
66 message->getProperty(prop);
82 logger.debug() <<
"Starting prefetcher output loop";
99 logger.debug() <<
"ProcessSourceEvent released";
101 ReverseLock<decltype(output_lock)> release_lock(output_lock);
111 logger.debug() <<
"Next source " <<
next.m_source_addr <<
" not done yet";
115 logger.debug() <<
"Source " <<
next.m_source_addr <<
" sent downstream";
117 ReverseLock<decltype(output_lock)> release_lock(output_lock);
129 logger.debug() <<
"Stopping prefetcher output loop";
139 logger.debug() <<
"ProcessSourceEvent received";
static Elements::Logging logger
static Logging getLogger(const std::string &name="")
size_t activeThreads() const