test/acl
1
0
Fork 0
mirror of https://gitee.com/acl-dev/acl.git synced 2024-12-14 08:50:53 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity
2f47091920
acl/lib_fiber/cpp/include/fiber/fiber_tbox.hpp

213 lines
4.2 KiB
C++
Raw Normal View History

Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
#pragma once
add fiber_tbox.hpp
2018-11-30 17:20:45 +08:00
#include "fiber_cpp_define.hpp"
#include <list>
fixed bugs of acl_fiber_cond_timedwait in acl_fiber_cond.c
2018-12-25 11:32:42 +08:00
#include <stdlib.h>
add fiber_tbox.hpp
2018-11-30 17:20:45 +08:00
#include "fiber_event.hpp"
#include "fiber_cond.hpp"
build for vc
2018-12-12 19:12:42 +08:00
#if !defined(_WIN32) && !defined(_WIN64)
optimize go fiber api for c++11
2020-06-13 14:33:08 +08:00
namespace acl {
add fiber_tbox.hpp
2018-11-30 17:20:45 +08:00
/**
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
* <EFBFBD><EFBFBD><EFBFBD><EFBFBD>Э<EFBFBD><EFBFBD>֮<EFBFBD>䣬<EFBFBD>߳<EFBFBD>֮<EFBFBD><EFBFBD><EFBFBD>Լ<EFBFBD>Э<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>߳<EFBFBD>֮<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϣͨ<EFBFBD>ţ<EFBFBD>ͨ<EFBFBD><EFBFBD>Э<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* <EFBFBD><EFBFBD>Э<EFBFBD><EFBFBD><EFBFBD>¼<EFBFBD><EFBFBD><EFBFBD>ʵ<EFBFBD><EFBFBD>
add fiber_tbox.hpp
2018-11-30 17:20:45 +08:00
*
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
* ʾ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
add fiber_tbox.hpp
2018-11-30 17:20:45 +08:00
*
* class myobj
* {
* public:
* myobj(void) {}
* ~myobj(void) {}
*
* void test(void) { printf("hello world\r\n"); }
* };
*
* acl::fiber_tbox<myobj> fiber_tbox;
*
* void thread_producer(void)
* {
* myobj* o = new myobj;
* fiber_tbox.push(o);
* }
*
* void thread_consumer(void)
* {
* myobj* o = fiber_tbox.pop();
* o->test();
* delete o;
* }
*/
template<typename T>
add http server module in fiber written by c++11
2020-06-24 16:46:05 +08:00
class fiber_tbox
add fiber_tbox.hpp
2018-11-30 17:20:45 +08:00
{
public:
/**
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
* <EFBFBD><EFBFBD><EFBFBD>췽<EFBFBD><EFBFBD>
* @param free_obj {bool} <EFBFBD><EFBFBD> fiber_tbox <EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʱ<EFBFBD><EFBFBD><EFBFBD>Ƿ<EFBFBD><EFBFBD>Զ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>鲢<EFBFBD>ͷ<EFBFBD>
* δ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ѵĶ<EFBFBD>̬<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
add fiber_tbox.hpp
2018-11-30 17:20:45 +08:00
*/
fixed one bug in fiber for stopping scheduling automatically
2019-01-14 14:34:14 +08:00
fiber_tbox(bool free_obj = true) : size_(0), free_obj_(free_obj) {}
add fiber_tbox.hpp
2018-11-30 17:20:45 +08:00
~fiber_tbox(void)
{
clear(free_obj_);
}
/**
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
* <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϣ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>δ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ѵ<EFBFBD><EFBFBD><EFBFBD>Ϣ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @param free_obj {bool} <EFBFBD>ͷŵ<EFBFBD><EFBFBD><EFBFBD> delete <EFBFBD><EFBFBD><EFBFBD><EFBFBD>ɾ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϣ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
add fiber_tbox.hpp
2018-11-30 17:20:45 +08:00
*/
void clear(bool free_obj = false)
{
if (free_obj) {
for (typename std::list<T*>::iterator it =
tbox_.begin(); it != tbox_.end(); ++it) {
delete *it;
}
}
tbox_.clear();
}
/**
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
* <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϣ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @param t {T*} <EFBFBD>ǿ<EFBFBD><EFBFBD><EFBFBD>Ϣ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @param notify_first {bool} <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϊ true<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ڲ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϣ<EFBFBD><EFBFBD>
* <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>֪ͨ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʽ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ƚ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>֪ͨ<EFBFBD><EFBFBD>ʽ<EFBFBD><EFBFBD><EFBFBD><EFBFBD> fiber_tbox <EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ڱȽϳ<EFBFBD>ʱ<EFBFBD><EFBFBD><EFBFBD>ò<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϊ false <EFBFBD><EFBFBD>Ч<EFBFBD>ʸ<EFBFBD><EFBFBD>ߣ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD> fiber_tbox
* <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ڽ϶<EFBFBD>(<EFBFBD>磺<EFBFBD>ȴ<EFBFBD><EFBFBD>ߵ<EFBFBD><EFBFBD><EFBFBD> pop <EFBFBD><EFBFBD>ֱ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD> fiber_tbox <EFBFBD><EFBFBD><EFBFBD><EFBFBD>),
* <EFBFBD>򱾲<EFBFBD><EFBFBD><EFBFBD>Ӧ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϊ true<EFBFBD><EFBFBD><EFBFBD>Ա<EFBFBD><EFBFBD><EFBFBD> push <EFBFBD>߻<EFBFBD>û<EFBFBD><EFBFBD><EFBFBD><EFBFBD>ȫ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>ǰ<EFBFBD><EFBFBD> fiber_tbox
* <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ǰ<EFBFBD><EFBFBD><EFBFBD>ٶ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ڴ<EFBFBD><EFBFBD>Ƿ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
fixed bugs of acl_fiber_cond_timedwait in acl_fiber_cond.c
2018-12-25 11:32:42 +08:00
* @return {bool}
add fiber_tbox.hpp
2018-11-30 17:20:45 +08:00
*/
fixed bugs of acl_fiber_cond_timedwait in acl_fiber_cond.c
2018-12-25 11:32:42 +08:00
bool push(T* t, bool notify_first = true)
add fiber_tbox.hpp
2018-11-30 17:20:45 +08:00
{
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
// <20>ȼ<EFBFBD><C8BC><EFBFBD>
fixed bugs of acl_fiber_cond_timedwait in acl_fiber_cond.c
2018-12-25 11:32:42 +08:00
if (event_.wait() == false) {
abort();
}
fixed bugs in client_wakeup of acl_threads_server.c; acl::fiber_tbox and acl::fiber_cond are ok.
2018-12-06 15:50:13 +08:00
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϣ<EFBFBD><CFA2><EFBFBD><EFBFBD>
add fiber_tbox.hpp
2018-11-30 17:20:45 +08:00
tbox_.push_back(t);
size_++;
fixed bugs in client_wakeup of acl_threads_server.c; acl::fiber_tbox and acl::fiber_cond are ok.
2018-12-06 15:50:13 +08:00
if (notify_first) {
fixed bugs of acl_fiber_cond_timedwait in acl_fiber_cond.c
2018-12-25 11:32:42 +08:00
if (cond_.notify() == false) {
abort();
}
if (event_.notify() == false) {
abort();
}
return true;
fixed bugs in client_wakeup of acl_threads_server.c; acl::fiber_tbox and acl::fiber_cond are ok.
2018-12-06 15:50:13 +08:00
} else {
fixed bugs of acl_fiber_cond_timedwait in acl_fiber_cond.c
2018-12-25 11:32:42 +08:00
if (event_.notify() == false) {
abort();
}
if (cond_.notify() == false) {
abort();
}
return true;
fixed bugs in client_wakeup of acl_threads_server.c; acl::fiber_tbox and acl::fiber_cond are ok.
2018-12-06 15:50:13 +08:00
}
add fiber_tbox.hpp
2018-11-30 17:20:45 +08:00
}
/**
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
* <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϣ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @param wait_ms {int} >= 0 ʱ<EFBFBD><EFBFBD><EFBFBD>õȴ<EFBFBD><EFBFBD><EFBFBD>ʱʱ<EFBFBD><EFBFBD>(<EFBFBD><EFBFBD><EFBFBD>뼶<EFBFBD><EFBFBD>)<EFBFBD><EFBFBD>
* <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Զ<EFBFBD>ȴ<EFBFBD>ֱ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϣ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @param found {bool*} <EFBFBD>ǿ<EFBFBD>ʱ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ƿ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>һ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϣ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ҫ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ݿն<EFBFBD><EFBFBD><EFBFBD>ʱ<EFBFBD>ļ<EFBFBD><EFBFBD><EFBFBD>
* @return {T*} <EFBFBD><EFBFBD> NULL <EFBFBD><EFBFBD>ʾ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>һ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϣ<EFBFBD><EFBFBD><EFBFBD>󣬷<EFBFBD><EFBFBD><EFBFBD> NULL ʱ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ҫ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>һ
* <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>飬<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD> push <EFBFBD><EFBFBD>һ<EFBFBD><EFBFBD><EFBFBD>ն<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>NULL<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ҳ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD> NULL<EFBFBD><EFBFBD>
* <EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʱ<EFBFBD><EFBFBD>Ȼ<EFBFBD><EFBFBD>Ϊ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>һ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϣ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ֻ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϊ<EFBFBD>ն<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD> wait_ms <EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* Ϊ -1 ʱ<EFBFBD><EFBFBD><EFBFBD><EFBFBD> NULL <EFBFBD><EFBFBD>Ȼ<EFBFBD><EFBFBD>Ϊ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>һ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϣ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD> wait_ms <EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* <EFBFBD><EFBFBD><EFBFBD><EFBFBD> 0 ʱ<EFBFBD><EFBFBD><EFBFBD><EFBFBD> NULL<EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ӧ<EFBFBD>ü<EFBFBD><EFBFBD><EFBFBD> found <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ֵΪ true <EFBFBD><EFBFBD><EFBFBD><EFBFBD> false <EFBFBD><EFBFBD>
* <EFBFBD>ж<EFBFBD><EFBFBD>Ƿ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>һ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϣ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
add fiber_tbox.hpp
2018-11-30 17:20:45 +08:00
*/
T* pop(int wait_ms = -1, bool* found = NULL)
{
bool found_flag;
fixed bugs of acl_fiber_cond_timedwait in acl_fiber_cond.c
2018-12-25 11:32:42 +08:00
if (event_.wait() == false) {
abort();
}
add fiber_tbox.hpp
2018-11-30 17:20:45 +08:00
while (true) {
T* t = peek(found_flag);
if (found_flag) {
fixed bugs of acl_fiber_cond_timedwait in acl_fiber_cond.c
2018-12-25 11:32:42 +08:00
if (event_.notify() == false) {
abort();
}
add fiber_tbox.hpp
2018-11-30 17:20:45 +08:00
if (found) {
*found = found_flag;
}
return t;
}
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
// ע<><D7A2><EFBFBD><EFBFBD><EFBFBD><EFBFBD>˳<EFBFBD>򣬱<EFBFBD><F2A3ACB1><EFBFBD><EFBFBD>ȵ<EFBFBD><C8B5><EFBFBD> wait <20><><EFBFBD>ж<EFBFBD> wait_ms
add fiber_tbox.hpp
2018-11-30 17:20:45 +08:00
if (!cond_.wait(event_, wait_ms) && wait_ms >= 0) {
fixed bugs of acl_fiber_cond_timedwait in acl_fiber_cond.c
2018-12-25 11:32:42 +08:00
if (event_.notify() == false) {
abort();
}
add fiber_tbox.hpp
2018-11-30 17:20:45 +08:00
if (found) {
*found = false;
}
return NULL;
}
}
}
/**
Revert "All source code have been changed to use utf8 charset with BOM header!" This reverts commit 15d999759eabbf2568053d9d864e06ad876a5593.
2019-07-28 10:31:56 +08:00
* <EFBFBD><EFBFBD><EFBFBD>ص<EFBFBD>ǰ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϣ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>е<EFBFBD><EFBFBD><EFBFBD>Ϣ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
add fiber_tbox.hpp
2018-11-30 17:20:45 +08:00
* @return {size_t}
*/
size_t size(void) const
{
return size_;
}
public:
void lock(void)
{
fixed bugs of acl_fiber_cond_timedwait in acl_fiber_cond.c
2018-12-25 11:32:42 +08:00
if (event_.wait() == false) {
abort();
}
add fiber_tbox.hpp
2018-11-30 17:20:45 +08:00
}
void unlock(void)
{
fixed bugs of acl_fiber_cond_timedwait in acl_fiber_cond.c
2018-12-25 11:32:42 +08:00
if (event_.notify() == false) {
abort();
}
add fiber_tbox.hpp
2018-11-30 17:20:45 +08:00
}
private:
fiber_tbox(const fiber_tbox&) {}
const fiber_tbox& operator=(const fiber_tbox&);
private:
std::list<T*> tbox_;
size_t size_;
bool free_obj_;
fiber_event event_;
fiber_cond cond_;
T* peek(bool& found_flag)
{
typename std::list<T*>::iterator it = tbox_.begin();
if (it == tbox_.end()) {
found_flag = false;
return NULL;
}
found_flag = true;
size_--;
T* t = *it;
tbox_.erase(it);
return t;
}
};
} // namespace acl
build for vc
2018-12-12 19:12:42 +08:00
#endif
Reference in New Issue Copy Permalink