// 实现原理
// 每个signal映射到bitset位，全集
// 每个slot做为signal的bitset子集
// signal全集触发，标志位有效
// flip将触发事件队列前置
// slot检测智能指针全集触发的标志位，主动运行子集绑定的函数
// 下一帧对bitset全集进行触发清空，防止slot一直检测到signal触发
#include <any>
#include <iostream>
#include "blinker.h"
void testMatch() {
blinker::SignalTrie<1024> trie;
trie.Put("ab.cd.ef", 1);
trie.Put("ab.cd.kk", 2);
trie.Put("ab.xy.zz", 3);
trie.Put("tt.xx", 4);
trie.Put("ab.cd", 5);
auto m1 = trie.Match("ab.cd.ef");
//REQUIRE(m1.count() == 1);
//REQUIRE(m1[1]);
auto m2 = trie.Match("ab.cd.kk");
//REQUIRE(m2.count() == 1);
//REQUIRE(m2[2]);
auto m3 = trie.Match("ab.xy.zz");
//REQUIRE(m3.count() == 1);
//REQUIRE(m3[3]);
auto m4 = trie.Match("ab.not.found");
//REQUIRE(m4.count() == 0);
auto m5 = trie.Match("ab.*");
//REQUIRE(m5.count() == 4);
//REQUIRE(m5[1]);
//REQUIRE(m5[2]);
//REQUIRE(m5[3]);
//REQUIRE(m5[5]);
auto m6 = trie.Match("*");
//REQUIRE(m6.count() == 5);
//REQUIRE(m6[1]);
//REQUIRE(m6[2]);
//REQUIRE(m6[3]);
//REQUIRE(m6[4]);
//REQUIRE(m6[5]);
auto m7 = trie.Match("ab.cd.*");
//REQUIRE(m7.count() == 2);
//REQUIRE(m7[1]);
//REQUIRE(m7[2]);
auto m8 = trie.Match("tt.xx.");
//REQUIRE(m8.count() == 0);
auto m9 = trie.Match("tt.xx.*");
//REQUIRE(m9.count() == 0);
auto m10 = trie.Match("ab.cd");
//REQUIRE(m10.count() == 1);
//REQUIRE(m10[5]);
}
void testValue() {
struct Data {
int value = 1;
Data(int value) : value(value) {}
};
blinker::Board board;
auto signal1 = board.NewSignal("ab.cd");
auto signal2 = board.NewSignal("ab.ef");
auto signal3 = board.NewSignal("xy.zk");
auto conn1 = board.Connect("ab.*");
auto conn2 = board.Connect("ab.cd");
auto conn3 = board.Connect("ab.ef");
auto conn4 = board.Connect("xy.zk");
auto conn5 = board.Connect("*");
bool conn1CallbackCalled = false;
bool conn2CallbackCalled = false;
bool conn3CallbackCalled = false;
bool conn4CallbackCalled = false;
bool conn5CallbackCalled = false;
auto tick = [&]() {
signal1->Emit(std::make_shared<Data>(1));
signal2->Emit(std::make_shared<Data>(2));
signal3->Emit(std::make_shared<Data>(3));
// signal1 and signal2
conn1->Poll([&](const blinker::SignalId id, std::any data) {
conn1CallbackCalled = true;
auto p = std::any_cast<std::shared_ptr<Data>>(data);
if (id == signal1->Id())
std::cout << "value: " << p->value << std::endl;
else if (id == signal2->Id())
std::cout << "value: " << p->value << std::endl;
else
std::cout << "value error!" << std::endl;
});
// signal1
conn2->Poll([&](const blinker::SignalId id, std::any data) {
conn2CallbackCalled = true;
auto p = std::any_cast<std::shared_ptr<Data>>(data);
if (id == signal1->Id())
std::cout << "value: " << p->value << std::endl;
else
std::cout << "value error!" << std::endl;
});
// signal2
conn3->Poll([&](const blinker::SignalId id, std::any data) {
conn3CallbackCalled = true;
auto p = std::any_cast<std::shared_ptr<Data>>(data);
if (id == signal2->Id())
std::cout << "value: " << p->value << std::endl;
else
std::cout << "value error!" << std::endl;
});
// signal3
conn4->Poll([&](const blinker::SignalId id, std::any data) {
conn4CallbackCalled = true;
auto p = std::any_cast<std::shared_ptr<Data>>(data);
if (id == signal3->Id())
std::cout << "value: " << p->value << std::endl;
else
std::cout << "value error!" << std::endl;
});
// all signals
conn5->Poll([&](const blinker::SignalId id, std::any data) {
conn5CallbackCalled = true;
auto p = std::any_cast<std::shared_ptr<Data>>(data);
if (id == signal1->Id())
std::cout << "value: " << p->value << std::endl;
else if (id == signal2->Id())
std::cout << "value: " << p->value << std::endl;
else if (id == signal3->Id())
std::cout << "value: " << p->value << std::endl;
else
std::cout << "value error!" << std::endl;
});
board.Flip();
};
tick();
// still not called.
tick();
// called after flip
}
int testLoops() {
// Creates a board.
blinker::Board board;
// Creates signals.
auto taskStarted = board.NewSignal("task.started");
auto taskEnded = board.NewSignal("task.ended");
auto actionStarted = board.NewSignal("action.started");
// Creates connection to match some signals.
auto connection = board.Connect("task.*");
// Callback to be called on signal fire.
auto callback = [&](const blinker::SignalId id, std::any data) {
if (id == taskStarted->Id())
std::cout << "signal taskStarted:";
else if (id == taskEnded->Id())
std::cout << "signal taskEnded:";
else if (id == actionStarted->Id())
std::cout << "signal actionStarted-:";
std::cout << std::any_cast<int>(data) << std::endl;
};
// Assuming your main tick function here.
for (int i = 0; i < 10; i++) {
// Emit some signals (to backend).
taskStarted->Emit(i);
taskEnded->Emit(i);
actionStarted->Emit(i);
// Poll from frontend.
connection->Poll(callback);
// Flip double buffers.
board.Flip();
}
return 0;
}
void test() {
testMatch();
testValue();
testLoops();
}输出
value: 1
value: 2
value: 1
value: 2
value: 3
value: 1
value: 2
value: 3
signal taskStarted:0
signal taskEnded:0
signal taskStarted:1
signal taskEnded:1
signal taskStarted:2
signal taskEnded:2
signal taskStarted:3
signal taskEnded:3
signal taskStarted:4
signal taskEnded:4
signal taskStarted:5
signal taskEnded:5
signal taskStarted:6
signal taskEnded:6
signal taskStarted:7
signal taskEnded:7
signal taskStarted:8
signal taskEnded:8参考
GitHub - hit9/blinker.h: A lightweight signal/event library for C++, similar to Python's blinker, but designed to work with ticking loops.
创作不易，小小的支持一下吧！
