[IPC] Use first worker
This commit is contained in:
parent
f81f820b47
commit
cd15ad88cd
@ -9,7 +9,7 @@ namespace Utils
|
||||
if(this->remove) boost::interprocess::message_queue::remove(this->name.data());
|
||||
queue.reset(new boost::interprocess::message_queue(boost::interprocess::open_or_create, this->name.data(), _queueSize, _bufferSize + sizeof(Channel::Header)));
|
||||
|
||||
this->queueThread = std::thread(&Channel::queueWorker2, this);
|
||||
this->queueThread = std::thread(&Channel::queueWorker, this);
|
||||
}
|
||||
|
||||
Channel::~Channel()
|
||||
@ -113,25 +113,6 @@ namespace Utils
|
||||
}
|
||||
}
|
||||
|
||||
void Channel::queueWorker2()
|
||||
{
|
||||
while (!this->terminateQueue)
|
||||
{
|
||||
if(!this->internalQueue.empty())
|
||||
{
|
||||
std::lock_guard<std::mutex> lock(this->queueMutex);
|
||||
|
||||
std::string data = this->internalQueue.front();
|
||||
if(this->queue->try_send(data.data(), data.size(), 0))
|
||||
{
|
||||
this->internalQueue.pop();
|
||||
}
|
||||
}
|
||||
|
||||
std::this_thread::sleep_for(1000us);
|
||||
}
|
||||
}
|
||||
|
||||
void Channel::queueWorker()
|
||||
{
|
||||
while (!this->terminateQueue)
|
||||
|
@ -47,7 +47,6 @@ namespace Utils
|
||||
|
||||
void enqueueMessage(std::string data);
|
||||
void queueWorker();
|
||||
void queueWorker2();
|
||||
|
||||
bool terminateQueue;
|
||||
std::condition_variable queueEvent;
|
||||
|
Loading…
Reference in New Issue
Block a user