MayaFlux 0.1.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 117 of file Scheduler.cpp.

118{
119 for (const auto& token : m_token_clocks) {
120 process_token(token.first, 0);
121 }
122
123 static uint64_t cleanup_counter = 0;
124 if (++cleanup_counter % m_cleanup_threshold == 0) {
126 }
127}
static MayaFlux::Nodes::ProcessingToken token
Definition Timers.cpp:8
void cleanup_completed_tasks()
Clean up completed tasks in a 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.
std::unordered_map< ProcessingToken, std::unique_ptr< IClock > > m_token_clocks
Clock instances for each processing domain.

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

+ Here is the call graph for this function: