class InferenceEngine::CPUStreamsExecutor

Overview

CPU Streams executor implementation. The executor splits the CPU into groups of threads, that can be pinned to cores or NUMA nodes. It uses custom threads to pull tasks from single queue. More…

#include <ie_cpu_streams_executor.hpp>

class CPUStreamsExecutor: public InferenceEngine::IStreamsExecutor
{
public:
    // typedefs

    typedef std::shared_ptr<CPUStreamsExecutor> Ptr;

    // construction

    CPUStreamsExecutor(const IStreamsExecutor::Config& config = {});

    // methods

    virtual void run(Task task);
    virtual void Execute(Task task);
    virtual int GetStreamId();
    virtual int GetNumaNodeId();
    virtual int GetSocketId();
};

Inherited Members

public:
    // typedefs

    typedef std::shared_ptr<ITaskExecutor> Ptr;
    typedef std::shared_ptr<IStreamsExecutor> Ptr;

    // enums

    enum ThreadBindingType;

    // structs

    struct Config;
    struct Config;

    // methods

    virtual void run(Task task) = 0;
    virtual void run_and_wait(const std::vector<Task>& tasks);
    virtual void runAndWait(const std::vector<Task>& tasks);
    virtual int get_stream_id() = 0;
    virtual int get_numa_node_id() = 0;
    virtual int get_socket_id() = 0;
    virtual void execute(Task task) = 0;
    virtual int GetStreamId() = 0;
    virtual int GetNumaNodeId() = 0;
    virtual int GetSocketId() = 0;
    virtual void Execute(Task task) = 0;
    virtual int get_stream_id();
    virtual int get_numa_node_id();
    virtual int get_socket_id();
    virtual void execute(Task task);

Detailed Documentation

CPU Streams executor implementation. The executor splits the CPU into groups of threads, that can be pinned to cores or NUMA nodes. It uses custom threads to pull tasks from single queue.

Typedefs

typedef std::shared_ptr<CPUStreamsExecutor> Ptr

A shared pointer to a CPUStreamsExecutor object.

Construction

CPUStreamsExecutor(const IStreamsExecutor::Config& config = {})

Constructor.

Parameters:

config

Stream executor parameters

Methods

virtual void run(Task task)

Execute ov::Task inside task executor context.

Parameters:

task	A task to start

virtual void Execute(Task task)

Execute the task in the current thread using streams executor configuration and constraints.

Parameters:

task	A task to start

virtual int GetStreamId()

Return the index of current stream.

Returns:

An index of current stream. Or throw exceptions if called not from stream thread

virtual int GetNumaNodeId()

Return the id of current NUMA Node.

Returns:

ID of current NUMA Node, or throws exceptions if called not from stream thread

virtual int GetSocketId()

Return the id of current socket.

Returns:

ID of current socket, or throws exceptions if called not from stream thread