AsyncCallbackManager Class Reference

#include <AsyncExecutionCallback.hpp>

Public Member Functions
std::shared_ptr< AsyncExecutionCallback >	GetNewCallback ()
std::shared_ptr< AsyncExecutionCallback >	GetNotifiedCallback ()

Detailed Description

Definition at line 75 of file AsyncExecutionCallback.hpp.

Member Function Documentation

GetNewCallback()

std::shared_ptr< AsyncExecutionCallback > GetNewCallback

(

)

Definition at line 48 of file AsyncExecutionCallback.cpp.

{
    auto cb = std::make_unique<AsyncExecutionCallback>(m_NotificationQueue
#if !defined(ARMNN_DISABLE_THREADS)
                                                       , m_Mutex
                                                       , m_Condition
#endif
        );
    InferenceId id = cb->GetInferenceId();
    m_Callbacks.insert({id, std::move(cb)});
 
    return m_Callbacks.at(id);
}

GetNotifiedCallback()

std::shared_ptr< AsyncExecutionCallback > GetNotifiedCallback

(

)

Definition at line 62 of file AsyncExecutionCallback.cpp.

{
#if !defined(ARMNN_DISABLE_THREADS)
    std::unique_lock<std::mutex> lock(m_Mutex);
 
    m_Condition.wait(lock, [this] { return !m_NotificationQueue.empty(); });
#endif
    InferenceId id = m_NotificationQueue.front();
    m_NotificationQueue.pop();
 
    std::shared_ptr<AsyncExecutionCallback> callback = m_Callbacks.at(id);
    m_Callbacks.erase(id);
    return callback;
}

---

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

• src/armnn/AsyncExecutionCallback.hpp
• src/armnn/AsyncExecutionCallback.cpp