00001 #ifndef __TESTRINGBUFFER__
00002 #define __TESTRINGBUFFER__
00003
00004 #include "RingBuffer.h"
00005 #include <QThread>
00006 #include <iostream>
00007
00008 static RingBuffer rb(2,100);
00009
00010 class TestRingBufferWrite : public QThread
00011 {
00012 public:
00013
00014 void run()
00015 {
00016 int8_t* writeSlot;
00017 writeSlot = new int8_t[2];
00018 writeSlot[0] = *"a";
00019 writeSlot[1] = *"b";
00020 while (true) {
00021
00022 rb.insertSlotBlocking(writeSlot);
00023
00024 }
00025 }
00026
00027 };
00028
00029
00030 class TestRingBufferRead : public QThread
00031 {
00032 public:
00033
00034 void run()
00035 {
00036 int8_t* readSlot;
00037 readSlot = new int8_t[2];
00038 while (true) {
00039
00040 rb.readSlotBlocking(readSlot);
00041
00042
00043
00044 }
00045 }
00046 };
00047
00048 #endif
00049