breeze/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-02-08 01:33:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update unit tests (#114)

Browse Source 
* test: add memory_unittest
This commit is contained in:
Sonullx Liu
2020-10-19 16:51:25 +08:00
committed by GitHub
parent e74115bec0
commit bd79faabdc
2 changed files with 45 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
test/CMakeLists.txt
View File

@@ -36,6 +36,7 @@ set(TEST_LIST
mysql_unittest
facilities_unittest
graph_unittest
memory_unittest
)
if (APPLE)

44
test/memory_unittest.cc Normal file
View File

@@ -0,0 +1,44 @@
#include <vector>
#include <gtest/gtest.h>
#include "workflow/WFTaskFactory.h"
TEST(memory_unittest, dismiss)
{
std::vector<SubTask *> tasks;
auto http_task = WFTaskFactory::create_http_task("https://sogou.com", 0, 0, nullptr);
tasks.push_back(http_task);
auto redis_task = WFTaskFactory::create_redis_task("redis://username:password@127.0.0.1:6676/1", 0, nullptr);
tasks.push_back(redis_task);
auto mysql_task = WFTaskFactory::create_mysql_task("mysql://username:password@127.0.0.1:8899/db", 0, nullptr);
tasks.push_back(mysql_task);
auto timer_task = WFTaskFactory::create_timer_task(0, nullptr);
tasks.push_back(timer_task);
auto counter_task = WFTaskFactory::create_counter_task("", 0, nullptr);
tasks.push_back(counter_task);
auto go_task = WFTaskFactory::create_go_task("", [](){});
tasks.push_back(go_task);
auto thread_task = WFThreadTaskFactory<int, int>::create_thread_task("", [](int *, int *){}, nullptr);
tasks.push_back(thread_task);
auto graph_task = WFTaskFactory::create_graph_task(nullptr);
auto &node_a = graph_task->create_graph_node(WFTaskFactory::create_timer_task(0, nullptr));
auto &node_b = graph_task->create_graph_node(WFTaskFactory::create_timer_task(0, nullptr));
node_a -->-- node_b;
tasks.push_back(graph_task);
auto parallel_work = Workflow::create_parallel_work(nullptr);
for (auto task : tasks)
{
auto series_work = Workflow::create_series_work(task, nullptr);
parallel_work->add_series(series_work);
}
parallel_work->dismiss();
}