我可以使用 boost::threadpool 作为“线程安全队列”吗？

发布于 2024-08-16 13:08:29 字数 201 浏览 8 评论 0原文

我需要的实际上是一个线程安全的队列结构，其中多个客户端不断将数据转储到队列中，一个工作线程不断处理并弹出队列，

STL或Boost中是否存在任何完善的解决方案？

我现在考虑使用 Boost::threadpool 来做到这一点。只需将并行线程数设置为 1，每当客户端有新消息到达时，任务函数的输入参数就会更改。这是否有意义，是否有任何我尚未预料到的限制？

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

一瞬间的火花 2024-08-23 13:08:29

在boost中有一个消息队列类，这就是您所需要的：线程安全队列。

消息队列是进程间通信广泛使用的概念。消息队列是线程安全的队列，其主要特点是它会阻塞从空队列中读取数据并等待数据出现在其中。在该 boost 类中，还支持定时等待，并且在队列已满时阻塞写入器。

回复收藏 0 原文

若能看破又如何 2024-08-23 13:08:29

如果您在单进程应用程序中需要这样的框架，boost::asio::io_service 应该就足够了。这是一个使用 boost::thread 和 boost::asio::io_service 的工作框示例类。

#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <boost/thread.hpp>

class IWorkerThreadJob
{
    public:
        virtual ~IWorkerThreadJob(){};
        virtual void execute() = 0;
};


class BoostBasedWorkingBox
{
    public:

        BoostBasedWorkingBox():
            m_IOServiceWork(m_IOService), // Give some work to io_service or else it will simply return from ::run method .
            m_WorkerThread(boost::bind(&boost::asio::io_service::run, &m_IOService))
        {}

        ~BoostBasedWorkingBox()
        {
            m_IOService.stop();
            m_WorkerThread.join();
        }

        void processJob(IWorkerThreadJob* pJob)
        {
            m_IOService.post(boost::bind(&IWorkerThreadJob::execute,pJob));
        }   

    protected:
        boost::thread m_WorkerThread;
        boost::asio::io_service m_IOService;
        boost::asio::io_service::work m_IOServiceWork;


}

使用：-
实现 IWorkerThreadJob 接口。
从多个客户端调用 processJob 方法。

这里 boost::asio::io_service 充当线程安全队列。

If you need such a framework in a single process application, boost::asio::io_service should be sufficient. Here is a working box sample class using boost::thread and boost::asio::io_service.

#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <boost/thread.hpp>

class IWorkerThreadJob
{
    public:
        virtual ~IWorkerThreadJob(){};
        virtual void execute() = 0;
};


class BoostBasedWorkingBox
{
    public:

        BoostBasedWorkingBox():
            m_IOServiceWork(m_IOService), // Give some work to io_service or else it will simply return from ::run method .
            m_WorkerThread(boost::bind(&boost::asio::io_service::run, &m_IOService))
        {}

        ~BoostBasedWorkingBox()
        {
            m_IOService.stop();
            m_WorkerThread.join();
        }

        void processJob(IWorkerThreadJob* pJob)
        {
            m_IOService.post(boost::bind(&IWorkerThreadJob::execute,pJob));
        }   

    protected:
        boost::thread m_WorkerThread;
        boost::asio::io_service m_IOService;
        boost::asio::io_service::work m_IOServiceWork;


}

Use:-
Implement IWorkerThreadJob interface.
Call processJob method from multiple clients.

Here boost::asio::io_service acts as a thread safe queue.

回复收藏 0 原文