blob: 802d4d9df6a44cc832be7e9151e8f20477a058c3 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
|
#pragma once
#include <bfc/platform/types.h>
#include <deque>
#include "../nu/AutoLock.h"
template <class SampleData>
class SampleQueue
{
public:
void PushFree(SampleData *new_sample)
{
queue_guard.Lock();
free_queue.push_front(new_sample);
queue_guard.Unlock();
}
void PushProcessed(SampleData *new_sample)
{
queue_guard.Lock();
processed_queue.push_front(new_sample);
queue_guard.Unlock();
}
// will return 0 if none ready
SampleData *PopProcessed()
{
SampleData *sample=0;
queue_guard.Lock();
if (!processed_queue.empty())
{
sample = processed_queue.back();
processed_queue.pop_back();
}
queue_guard.Unlock();
return sample;
}
SampleData *PopFree()
{
SampleData *sample=0;
queue_guard.Lock();
if (!free_queue.empty())
{
sample = free_queue.back();
free_queue.pop_back();
}
queue_guard.Unlock();
if (!sample)
sample = new SampleData;
return sample;
}
void Trim()
{
queue_guard.Lock();
//free_queue.deleteAll();
auto it_f = free_queue.begin();
while (it_f != free_queue.end())
{
SampleData* p = *it_f;
delete p;
it_f = free_queue.erase(it_f);
}
//processed_queue.deleteAll();
auto it_p = processed_queue.begin();
while (it_p != processed_queue.end())
{
SampleData* p = *it_p;
delete p;
it_p = processed_queue.erase(it_p);
}
queue_guard.Unlock();
}
private:
std::deque<SampleData*> free_queue;
std::deque<SampleData*> processed_queue;
Nullsoft::Utility::LockGuard queue_guard;
};
|
