MayaFlux 1.0.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 339 of file Scheduler.cpp.

340{
341 for (const auto& token : m_token_clocks) {
342 process_token(token.first, 0);
343 }
344
345 static uint64_t cleanup_counter = 0;
346 if (++cleanup_counter % m_cleanup_threshold == 0) {
348 }
349}
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: