dd0060a582
* Deprecate legacy Core and Allocator * Suppress blob warnings * Suppress some warnings * Suppress more warnings * Suppress blob allocator * Suppress more warnings * Suppress more warnings * Fixed compilation issues for Template plugin * Fixed some warnings * Fixed tests * Add WA for benchmark_app * Suppress #warning for developer package * Rename define * Disable warnings for compile_tool and benchmark_app * Suppress Windows warnings * Suppress more warnings for Windows * Fixed compile_tool install * Added message for VS * Fixed snippets and throw only first error
63 lines
2.2 KiB
C++
63 lines
2.2 KiB
C++
// Copyright (C) 2018-2020 Intel Corporation
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
//
|
|
|
|
#ifndef IN_OV_COMPONENT
|
|
# define IN_OV_COMPONENT
|
|
# define WAS_OV_LIBRARY_DEFINED
|
|
#endif
|
|
#include <threading/ie_cpu_streams_executor.hpp>
|
|
|
|
#ifdef WAS_OV_LIBRARY_DEFINED
|
|
# undef IN_OV_COMPONENT
|
|
# undef WAS_OV_LIBRARY_DEFINED
|
|
#endif
|
|
|
|
#include <memory>
|
|
#include <future>
|
|
#include <iostream>
|
|
|
|
void example1() {
|
|
// ! [itask_executor:define_pipeline]
|
|
// std::promise is move only object so to satisfy copy callable constraint we use std::shared_ptr
|
|
auto promise = std::make_shared<std::promise<void>>();
|
|
// When the promise is created we can get std::future to wait the result
|
|
auto future = promise->get_future();
|
|
// Rather simple task
|
|
InferenceEngine::Task task = [] {std::cout << "Some Output" << std::endl; };
|
|
// Create an executor
|
|
InferenceEngine::ITaskExecutor::Ptr taskExecutor = std::make_shared<InferenceEngine::CPUStreamsExecutor>();
|
|
if (taskExecutor == nullptr) {
|
|
// ProcessError(e);
|
|
return;
|
|
}
|
|
// We capture the task and the promise. When the task is executed in the task executor context
|
|
// we munually call std::promise::set_value() method
|
|
taskExecutor->run([task, promise] {
|
|
std::exception_ptr currentException;
|
|
try {
|
|
task();
|
|
} catch(...) {
|
|
// If there is some exceptions store the pointer to current exception
|
|
currentException = std::current_exception();
|
|
}
|
|
|
|
if (nullptr == currentException) {
|
|
promise->set_value(); // <-- If there is no problems just call std::promise::set_value()
|
|
} else {
|
|
promise->set_exception(currentException); // <-- If there is an exception forward it to std::future object
|
|
}
|
|
});
|
|
// To wait the task completion we call std::future::wait method
|
|
future.wait(); // The current thread will be blocked here and wait when std::promise::set_value()
|
|
// or std::promise::set_exception() method will be called.
|
|
|
|
// If the future store the exception it will be rethrown in std::future::get method
|
|
try {
|
|
future.get();
|
|
} catch(std::exception& /*e*/) {
|
|
// ProcessError(e);
|
|
}
|
|
// ! [itask_executor:define_pipeline]
|
|
}
|