boost::fiber 安排 - 时间和方式
boost::fiber scheduling - when and how
根据文档
the currently-running fiber retains control until it invokes some
operation that passes control to the manager
我只能考虑一个操作 - boost::this_fiber::yield
这可能会导致从光纤到光纤的控制切换。然而,当我 运行 像
bf::fiber([](){std::cout << "Bang!" << std::endl;}).detach();
bf::fiber([](){std::cout << "Bung!" << std::endl;}).detach();
我得到类似
的输出
Bang!Bung!
\n
\n
这意味着控制在 <<
操作员之间从一根光纤传递到另一根光纤。这怎么可能发生?为什么?在 boost::fiber
库的上下文中,从光纤到光纤的控制的一般定义是什么?
编辑001:
没有代码无法逃脱:
#include <boost/fiber/fiber.hpp>
#include <boost/fiber/mutex.hpp>
#include <boost/fiber/barrier.hpp>
#include <boost/fiber/algo/algorithm.hpp>
#include <boost/fiber/algo/work_stealing.hpp>
namespace bf = boost::fibers;
class GreenExecutor
{
std::thread worker;
bf::condition_variable_any cv;
bf::mutex mtx;
bf::barrier barrier;
public:
GreenExecutor() : barrier {2}
{
worker = std::thread([this] {
bf::use_scheduling_algorithm<bf::algo::work_stealing>(2);
// wait till all threads joining the work stealing have been registered
barrier.wait();
mtx.lock();
// suspend main-fiber from the worker thread
cv.wait(mtx);
mtx.unlock();
});
bf::use_scheduling_algorithm<bf::algo::work_stealing>(2);
// wait till all threads have been registered the scheduling algorithm
barrier.wait();
}
template<typename T>
void PostWork(T&& functor)
{
bf::fiber {std::move(functor)}.detach();
}
~GreenExecutor()
{
cv.notify_all();
worker.join();
}
};
int main()
{
GreenExecutor executor;
std::this_thread::sleep_for(std::chrono::seconds(1));
int i = 0;
for (auto j = 0ul; j < 10; ++j) {
executor.PostWork([idx {++i}]() {
auto res = pow(sqrt(sin(cos(tan(idx)))), M_1_PI);
std::cout << idx << " - " << res << std::endl;
});
}
while (true) {
boost::this_fiber::yield();
}
return 0;
}
输出
2 - 1 - -nan
0.503334 3 - 4 - 0.861055
0.971884 5 - 6 - 0.968536
-nan 7 - 8 - 0.921959
0.9580699
- 10 - 0.948075
0.961811
好吧,我漏掉了几件事,首先,我的结论是基于对 boost::fiber
中的工作原理的误解
问题中提到的构造函数中的行
bf::use_scheduling_algorithm<bf::algo::work_stealing>(2);
在创建 GreenExecutor
实例的线程中安装调度程序(在主线程中)所以,当启动两个 worker fiber
s 时,我实际上启动了两个将要处理提交的线程 fiber
s 反过来会异步处理这些 fibers
从而混合 std::cout
输出。没有魔法,一切都按预期工作,boost::fiber::yield
仍然是将控制权从一根光纤传递到另一根光纤的唯一选择
根据文档
the currently-running fiber retains control until it invokes some operation that passes control to the manager
我只能考虑一个操作 - boost::this_fiber::yield
这可能会导致从光纤到光纤的控制切换。然而,当我 运行 像
bf::fiber([](){std::cout << "Bang!" << std::endl;}).detach();
bf::fiber([](){std::cout << "Bung!" << std::endl;}).detach();
我得到类似
的输出Bang!Bung!
\n
\n
这意味着控制在 <<
操作员之间从一根光纤传递到另一根光纤。这怎么可能发生?为什么?在 boost::fiber
库的上下文中,从光纤到光纤的控制的一般定义是什么?
编辑001: 没有代码无法逃脱:
#include <boost/fiber/fiber.hpp>
#include <boost/fiber/mutex.hpp>
#include <boost/fiber/barrier.hpp>
#include <boost/fiber/algo/algorithm.hpp>
#include <boost/fiber/algo/work_stealing.hpp>
namespace bf = boost::fibers;
class GreenExecutor
{
std::thread worker;
bf::condition_variable_any cv;
bf::mutex mtx;
bf::barrier barrier;
public:
GreenExecutor() : barrier {2}
{
worker = std::thread([this] {
bf::use_scheduling_algorithm<bf::algo::work_stealing>(2);
// wait till all threads joining the work stealing have been registered
barrier.wait();
mtx.lock();
// suspend main-fiber from the worker thread
cv.wait(mtx);
mtx.unlock();
});
bf::use_scheduling_algorithm<bf::algo::work_stealing>(2);
// wait till all threads have been registered the scheduling algorithm
barrier.wait();
}
template<typename T>
void PostWork(T&& functor)
{
bf::fiber {std::move(functor)}.detach();
}
~GreenExecutor()
{
cv.notify_all();
worker.join();
}
};
int main()
{
GreenExecutor executor;
std::this_thread::sleep_for(std::chrono::seconds(1));
int i = 0;
for (auto j = 0ul; j < 10; ++j) {
executor.PostWork([idx {++i}]() {
auto res = pow(sqrt(sin(cos(tan(idx)))), M_1_PI);
std::cout << idx << " - " << res << std::endl;
});
}
while (true) {
boost::this_fiber::yield();
}
return 0;
}
输出
2 - 1 - -nan
0.503334 3 - 4 - 0.861055
0.971884 5 - 6 - 0.968536
-nan 7 - 8 - 0.921959
0.9580699
- 10 - 0.948075
0.961811
好吧,我漏掉了几件事,首先,我的结论是基于对 boost::fiber
中的工作原理的误解
问题中提到的构造函数中的行
bf::use_scheduling_algorithm<bf::algo::work_stealing>(2);
在创建 GreenExecutor
实例的线程中安装调度程序(在主线程中)所以,当启动两个 worker fiber
s 时,我实际上启动了两个将要处理提交的线程 fiber
s 反过来会异步处理这些 fibers
从而混合 std::cout
输出。没有魔法,一切都按预期工作,boost::fiber::yield
仍然是将控制权从一根光纤传递到另一根光纤的唯一选择