MayaFlux 0.4.0
Digital-First Multimedia Processing Framework
Loading...
Searching...
No Matches

◆ process_all_tokens()

void MayaFlux::Vruta::TaskScheduler::process_all_tokens ( )

Process all active domains.

Processes all domains that have active tasks, advancing each domain's clock by its default processing unit size. Useful for unified processing in applications that need to advance all domains simultaneously.

Definition at line 241 of file Scheduler.cpp.

242{
243 for (const auto& token : m_token_clocks) {
244 process_token(token.first, 0);
245 }
246
247 static uint64_t cleanup_counter = 0;
248 if (++cleanup_counter % m_cleanup_threshold == 0) {
250 }
251}
void cleanup_completed_tasks()
Clean up completed tasks in a domain.
std::unordered_map< ProcessingToken, std::shared_ptr< IClock > > m_token_clocks
Clock instances for each processing domain.
void process_token(ProcessingToken token, uint64_t processing_units=1)
Process all tasks for a specific processing domain.
uint32_t m_cleanup_threshold
Threshold for task cleanup.

References cleanup_completed_tasks(), m_cleanup_threshold, m_token_clocks, and process_token().

+ Here is the call graph for this function: