我正在使用线程安全 Q 在缓冲区内生成一些随机数。在主 glWidget 程序上,我应该对缓冲区内容进行 DeQ 并更新屏幕。
#ifndef CONCURRENTQUEUE_H
#define CONCURRENTQUEUE_H
#include <QByteArray>
#include <QQueue>
#include <QMutex>
class ConcurrentQueue
{
private:
unsigned short segments[360][100];
public:
ConcurrentQueue();
void InitSegments();
void Enqueue(int i, int j, unsigned short value);
unsigned short Dequeue(int i, int j);
bool isEmpty();
private:
QMutex mutex;
};
#endif // CONCURRENTQUEUE_H
ConcurrentQueue::ConcurrentQueue()
{
InitSegments();
}
void ConcurrentQueue::InitSegments()
{
for(int i = 0; i < 360; i++)
for(int j = 0; j < 100; j++)
{
segments[i][j] = 0;
}
}
void ConcurrentQueue::Enqueue(int i, int j, unsigned short value)
{
mutex.lock();
segments[i][j] = value;
mutex.unlock();
}
unsigned short ConcurrentQueue::Dequeue(int i, int j)
{
unsigned short color = 0;
mutex.lock();
color = segments[i][j];
mutex.unlock();
return color;
}
生成缓冲区类:
#ifndef GENERATEBUFFERS_H
#define GENERATEBUFFERS_H
#include <QThread>
#include "thread_safe/concurrentqueue.h"
class GenerateBuffers : public QThread
{
public:
GenerateBuffers();
void run();
int rounds;
int segmentIndex;
};
#endif // GENERATEBUFFERS_H
#include "generatebuffers.h"
#include <time.h>
ConcurrentQueue segmentsQueue;
GenerateBuffers::GenerateBuffers()
{
segmentIndex = 1;
run();
}
void GenerateBuffers::run()
{
while(true)
{
int angleIndex = segmentIndex * 23;
for(int i = angleIndex - 23; i < angleIndex; i++)
for(int j = 0; j < 100; j++)
{
unsigned short randNumber = rand() % 255;
segmentsQueue.Enqueue(i, j, randNumber);
}
if(segmentIndex > 16)
{
segmentIndex = 0;
}
else
segmentIndex++;
usleep(150);
}
}
我在 generateBuffers .cpp 文件中创建了一个 ConcurrentQ 实例
ConcurrentQueue segmentsQueue;
在我声明的 glWidget 头文件中: extern ConcurrentQueue segmentsQueue;
我这样使用它:
ppi->highlight(j, i, segmentsQueue.Dequeue(i, j));
程序在我运行时终止,我不确定我的线程安全实现是否正确。你能告诉我你对代码的看法吗?