|
|
/*
|
|
|
* Copyright (c) 2016 The ZLToolKit project authors. All Rights Reserved.
|
|
|
*
|
|
|
* This file is part of ZLToolKit(https://github.com/ZLMediaKit/ZLToolKit).
|
|
|
*
|
|
|
* Use of this source code is governed by MIT license that can be found in the
|
|
|
* LICENSE file in the root of the source tree. All contributing project authors
|
|
|
* may be found in the AUTHORS file in the root of the source tree.
|
|
|
*/
|
|
|
|
|
|
#include <csignal>
|
|
|
#include <iostream>
|
|
|
#include "Util/logger.h"
|
|
|
#include "Util/util.h"
|
|
|
#include "Util/RingBuffer.h"
|
|
|
#include "Thread/threadgroup.h"
|
|
|
#include <list>
|
|
|
|
|
|
using namespace std;
|
|
|
using namespace toolkit;
|
|
|
|
|
|
//环形缓存写线程退出标记 [AUTO-TRANSLATED:ceeb4c96]
|
|
|
// Ring buffer write thread exit flag
|
|
|
bool g_bExitWrite = false;
|
|
|
|
|
|
//一个30个string对象的环形缓存 [AUTO-TRANSLATED:fee6a014]
|
|
|
// A ring buffer of 30 string objects
|
|
|
RingBuffer<string>::Ptr g_ringBuf(new RingBuffer<string>(30));
|
|
|
|
|
|
//写事件回调函数 [AUTO-TRANSLATED:19f6b6fa]
|
|
|
// Write event callback function
|
|
|
void onReadEvent(const string &str){
|
|
|
//读事件模式性 [AUTO-TRANSLATED:12cdd3a8]
|
|
|
// Read event mode
|
|
|
DebugL << str;
|
|
|
}
|
|
|
|
|
|
//环形缓存销毁事件 [AUTO-TRANSLATED:7da356eb]
|
|
|
// Ring buffer destruction event
|
|
|
void onDetachEvent(){
|
|
|
WarnL;
|
|
|
}
|
|
|
|
|
|
//写环形缓存任务 [AUTO-TRANSLATED:1467fea5]
|
|
|
// Write ring buffer task
|
|
|
void doWrite(){
|
|
|
int i = 0;
|
|
|
while(!g_bExitWrite){
|
|
|
//每隔100ms写一个数据到环形缓存 [AUTO-TRANSLATED:aedec620]
|
|
|
// Write data to the ring buffer every 100ms
|
|
|
g_ringBuf->write(to_string(++i),true);
|
|
|
usleep(100 * 1000);
|
|
|
}
|
|
|
|
|
|
}
|
|
|
int main() {
|
|
|
//初始化日志 [AUTO-TRANSLATED:371bb4e5]
|
|
|
// Initialize log
|
|
|
Logger::Instance().add(std::make_shared<ConsoleChannel>());
|
|
|
Logger::Instance().setWriter(std::make_shared<AsyncLogWriter>());
|
|
|
|
|
|
auto poller = EventPollerPool::Instance().getPoller();
|
|
|
RingBuffer<string>::RingReader::Ptr ringReader;
|
|
|
poller->sync([&](){
|
|
|
//从环形缓存获取一个读取器 [AUTO-TRANSLATED:c61b1c37]
|
|
|
// Get a reader from the ring buffer
|
|
|
ringReader = g_ringBuf->attach(poller);
|
|
|
|
|
|
//设置读取事件 [AUTO-TRANSLATED:6d9e7c68]
|
|
|
// Set read event
|
|
|
ringReader->setReadCB([](const string &pkt){
|
|
|
onReadEvent(pkt);
|
|
|
});
|
|
|
|
|
|
//设置环形缓存销毁事件 [AUTO-TRANSLATED:8fc24dc3]
|
|
|
// Set ring buffer destruction event
|
|
|
ringReader->setDetachCB([](){
|
|
|
onDetachEvent();
|
|
|
});
|
|
|
});
|
|
|
|
|
|
|
|
|
thread_group group;
|
|
|
//写线程 [AUTO-TRANSLATED:f91ceacd]
|
|
|
// Write thread
|
|
|
group.create_thread([](){
|
|
|
doWrite();
|
|
|
});
|
|
|
|
|
|
//测试3秒钟 [AUTO-TRANSLATED:942e7c08]
|
|
|
// Test for 3 seconds
|
|
|
sleep(3);
|
|
|
|
|
|
//通知写线程退出 [AUTO-TRANSLATED:b2b2a2af]
|
|
|
// Notify write thread to exit
|
|
|
g_bExitWrite = true;
|
|
|
//等待写线程退出 [AUTO-TRANSLATED:8150eaf3]
|
|
|
// Wait for write thread to exit
|
|
|
group.join_all();
|
|
|
|
|
|
//释放环形缓冲，此时异步触发Detach事件 [AUTO-TRANSLATED:3aaaa2f4]
|
|
|
// Release ring buffer, triggering Detach event asynchronously
|
|
|
g_ringBuf.reset();
|
|
|
//等待异步触发Detach事件 [AUTO-TRANSLATED:a6ea0f45]
|
|
|
// Wait for asynchronous Detach event trigger
|
|
|
sleep(1);
|
|
|
//消除对EventPoller对象的引用 [AUTO-TRANSLATED:4f22453d]
|
|
|
// Remove reference to EventPoller object
|
|
|
ringReader.reset();
|
|
|
sleep(1);
|
|
|
return 0;
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|