MayaFlux 0.2.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 119 of file Scheduler.cpp.

120{
121 for (const auto& token : m_token_clocks) {
122 process_token(token.first, 0);
123 }
124
125 static uint64_t cleanup_counter = 0;
126 if (++cleanup_counter % m_cleanup_threshold == 0) {
128 }
129}
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: