kcenon::thread::adaptive_job_queue::accuracy_guard Class Reference

RAII guard that temporarily switches to accuracy mode. More...

#include <adaptive_job_queue.h>

Collaboration diagram for kcenon::thread::adaptive_job_queue::accuracy_guard:

Public Member Functions
	accuracy_guard (adaptive_job_queue &queue)
	Construct guard and switch queue to mutex mode.
	~accuracy_guard ()
	Destructor - restores previous mode.
	accuracy_guard (accuracy_guard &&other) noexcept
accuracy_guard &	operator= (accuracy_guard &&)=delete
	accuracy_guard (const accuracy_guard &)=delete
accuracy_guard &	operator= (const accuracy_guard &)=delete

Private Attributes
adaptive_job_queue *	queue_
mode	previous_mode_
bool	active_

Detailed Description

RAII guard that temporarily switches to accuracy mode.

Definition at line 283 of file adaptive_job_queue.h.

Constructor & Destructor Documentation

accuracy_guard() [1/3]

kcenon::thread::adaptive_job_queue::accuracy_guard::accuracy_guard ( adaptive_job_queue & queue )

explicit

Construct guard and switch queue to mutex mode.

Parameters

queue

Reference to the adaptive queue

Definition at line 267 of file adaptive_job_queue.cpp.

    : queue_(&queue)
    , previous_mode_(queue.current_mode())
    , active_(true) {
 
    // Increment guard count
    int prev_count = queue_->accuracy_guard_count_.fetch_add(1, std::memory_order_acq_rel);
 
    // If this is the first guard and not already in mutex mode, switch
    if (prev_count == 0 && previous_mode_ != mode::mutex) {
        queue_->migrate_to_mode(mode::mutex);
    }
}

References kcenon::thread::adaptive_job_queue::accuracy_guard_count_, kcenon::thread::adaptive_job_queue::migrate_to_mode(), kcenon::thread::adaptive_job_queue::mutex, previous_mode_, and queue_.

Here is the call graph for this function:

~accuracy_guard()

kcenon::thread::adaptive_job_queue::accuracy_guard::~accuracy_guard

(

)

Destructor - restores previous mode.

Definition at line 281 of file adaptive_job_queue.cpp.

                                                  {
    if (!active_ || !queue_) {
        return;
    }
 
    // Decrement guard count
    int prev_count = queue_->accuracy_guard_count_.fetch_sub(1, std::memory_order_acq_rel);
 
    // If this was the last guard and we should restore previous mode
    if (prev_count == 1) {
        // Restore based on policy
        switch (queue_->policy_) {
            case policy::accuracy_first:
                // Stay in mutex mode
                break;
            case policy::performance_first:
                queue_->migrate_to_mode(mode::lock_free);
                break;
            case policy::balanced:
                // Let balanced policy decide
                {
                    mode target = queue_->determine_mode_for_balanced();
                    if (target != mode::mutex) {
                        queue_->migrate_to_mode(target);
                    }
                }
                break;
            case policy::manual:
                // Restore previous mode
                if (previous_mode_ != mode::mutex) {
                    queue_->migrate_to_mode(previous_mode_);
                }
                break;
        }
    }
}

References kcenon::thread::adaptive_job_queue::accuracy_first, kcenon::thread::adaptive_job_queue::balanced, kcenon::thread::adaptive_job_queue::lock_free, kcenon::thread::adaptive_job_queue::manual, kcenon::thread::adaptive_job_queue::mutex, and kcenon::thread::adaptive_job_queue::performance_first.

accuracy_guard() [2/3]

kcenon::thread::adaptive_job_queue::accuracy_guard::accuracy_guard ( accuracy_guard && other )

noexcept

Definition at line 318 of file adaptive_job_queue.cpp.

    : queue_(other.queue_)
    , previous_mode_(other.previous_mode_)
    , active_(other.active_) {
    other.active_ = false;
    other.queue_ = nullptr;
}

accuracy_guard() [3/3]

kcenon::thread::adaptive_job_queue::accuracy_guard::accuracy_guard ( const accuracy_guard & )

delete

Member Function Documentation

operator=() [1/2]

accuracy_guard & kcenon::thread::adaptive_job_queue::accuracy_guard::operator= ( accuracy_guard && )

delete

operator=() [2/2]

accuracy_guard & kcenon::thread::adaptive_job_queue::accuracy_guard::operator= ( const accuracy_guard & )

delete

Member Data Documentation

active_

bool kcenon::thread::adaptive_job_queue::accuracy_guard::active_

private

Definition at line 307 of file adaptive_job_queue.h.

previous_mode_

mode kcenon::thread::adaptive_job_queue::accuracy_guard::previous_mode_

private

Definition at line 306 of file adaptive_job_queue.h.

Referenced by accuracy_guard().

queue_

adaptive_job_queue* kcenon::thread::adaptive_job_queue::accuracy_guard::queue_

private

Definition at line 305 of file adaptive_job_queue.h.

Referenced by accuracy_guard().

---

The documentation for this class was generated from the following files:

• include/kcenon/thread/queue/adaptive_job_queue.h
• src/queue/adaptive_job_queue.cpp