#include "../utils/vp_utils.h"
|
#include "../utils/logger/vp_logger.h"
|
|
#include <iostream>
|
#include <chrono>
|
#include <thread>
|
|
/*
|
* ## sample for vp_logger ##
|
* show how vp_logger works
|
*/
|
|
int main() {
|
// config for log content
|
// VP_SET_LOG_INCLUDE_THREAD_ID(false);
|
// VP_SET_LOG_INCLUDE_CODE_LOCATION(false);
|
// VP_SET_LOG_INCLUDE_LEVEL(false);
|
|
// config for output
|
// VP_SET_LOG_TO_CONSOLE(false);
|
// VP_SET_LOG_TO_FILE(false);
|
|
// config for log folder
|
VP_SET_LOG_DIR("./log");
|
|
// config log level
|
VP_SET_LOG_LEVEL(vp_utils::vp_log_level::DEBUG);
|
|
// config for kafka, ignored automatically if not prepared for kafka
|
VP_SET_LOG_TO_KAFKA(true); // false by default if not set
|
VP_SET_LOG_KAFKA_SERVERS_AND_TOPIC("192.168.130.228:9092/vp_log");
|
|
// init
|
VP_LOGGER_INIT();
|
|
// 6 threads logging separately
|
auto func1 = []() {
|
while (true) {
|
/* code */
|
auto id = std::this_thread::get_id();
|
std::stringstream ss;
|
ss << std::hex << id;
|
auto thread_id = ss.str();
|
VP_ERROR(vp_utils::string_format("thread id: %s", thread_id.c_str()));
|
std::this_thread::sleep_for(std::chrono::milliseconds(2));
|
}
|
|
};
|
|
auto func2 = []() {
|
while (true) {
|
/* code */
|
auto id = std::this_thread::get_id();
|
std::stringstream ss;
|
ss << std::hex << id;
|
auto thread_id = ss.str();
|
VP_DEBUG(vp_utils::string_format("thread id: %s", thread_id.c_str()));
|
std::this_thread::sleep_for(std::chrono::milliseconds(13));
|
}
|
|
};
|
|
auto func3 = []() {
|
while (true) {
|
/* code */
|
auto id = std::this_thread::get_id();
|
std::stringstream ss;
|
ss << std::hex << id;
|
auto thread_id = ss.str();
|
VP_INFO(vp_utils::string_format("thread id: %s", thread_id.c_str()));
|
std::this_thread::sleep_for(std::chrono::milliseconds(4));
|
}
|
|
};
|
|
auto func4 = []() {
|
while (true) {
|
/* code */
|
auto id = std::this_thread::get_id();
|
std::stringstream ss;
|
ss << std::hex << id;
|
auto thread_id = ss.str();
|
VP_WARN(vp_utils::string_format("thread id: %s", thread_id.c_str()));
|
std::this_thread::sleep_for(std::chrono::milliseconds(10));
|
}
|
|
};
|
|
auto func5 = []() {
|
while (true) {
|
/* code */
|
auto id = std::this_thread::get_id();
|
std::stringstream ss;
|
ss << std::hex << id;
|
auto thread_id = ss.str();
|
VP_ERROR(vp_utils::string_format("thread id: %s", thread_id.c_str()));
|
std::this_thread::sleep_for(std::chrono::milliseconds(10));
|
}
|
|
};
|
|
auto func6 = []() {
|
while (true) {
|
/* code */
|
auto id = std::this_thread::get_id();
|
std::stringstream ss;
|
ss << std::hex << id;
|
auto thread_id = ss.str();
|
VP_INFO(vp_utils::string_format("thread id: %s", thread_id.c_str()));
|
std::this_thread::sleep_for(std::chrono::milliseconds(10));
|
}
|
|
};
|
|
std::thread t1(func1);
|
std::thread t2(func2);
|
std::thread t3(func3);
|
std::thread t4(func4);
|
std::thread t5(func5);
|
std::thread t6(func6);
|
|
t1.join();
|
t2.join();
|
t3.join();
|
t4.join();
|
t5.join();
|
t6.join();
|
|
std::getchar();
|
}
|
