GitHub/sdrtrunk
1
0
Fork 0
mirror of https://github.com/DSheirer/sdrtrunk.git synced 2026-11-10 23:57:25 -05:00
Code Issues Packages Projects Releases 2 Wiki Activity

Updates the overflowable queue to reduce thread contention on the queue size monitor

Browse Source
This commit is contained in:
Denny
2017-01-29 06:26:12 -05:00
parent 0c84984fcc
commit e6ab615931
1 changed files with 11 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/sample/OverflowableTransferQueue.java
View File

@@ -55,15 +55,14 @@ public class OverflowableTransferQueue<E>
{
if(!mOverflow)
{
if(mCounter.get() > mMaximumSize)
mQueue.offer(e);
int size = mCounter.incrementAndGet();
if(size > mMaximumSize)
{
setOverflow(true);
}
else
{
mQueue.offer(e);
mCounter.incrementAndGet();
}
}
}
@@ -76,7 +75,12 @@ public class OverflowableTransferQueue<E>
if(drainCount > 0)
{
mCounter.addAndGet(-drainCount);
int size = mCounter.addAndGet(-drainCount);
if(mOverflow && size <= mResetThreshold)
{
setOverflow(false);
}
}
return drainCount;