sparrowwallet/usb4java
sparrowwallet/usb4java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Improve IRP processing thread execution

Browse Source
This commit is contained in:
Klaus Reimer 2013-02-24 17:35:38 +01:00
parent 10bd83cc88
commit 40930d68d9
1 changed files with 20 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
src/main/java/de/ailis/usb4java/support/AbstractIrpQueue.java
View File

@ -75,11 +75,10 @@ public abstract class AbstractIrpQueue<T extends UsbIrp>
*/
final void process()
{
while (true)
// Get the next IRP
T irp = this.irps.poll();
while (irp != null)
{
// Get the next IRP
final T irp = this.irps.poll();
// Process the IRP
try
{
@ -97,20 +96,25 @@ public abstract class AbstractIrpQueue<T extends UsbIrp>
{
irp.setUsbException(e);
}
// Get next IRP and mark the thread as closing before sending the
// events for the previous IRP
T nextIrp = this.irps.poll();
if (nextIrp == null) this.processor = null;
// Finish the previous IRP
irp.complete();
finishIrp(irp);
// When no more IRPs are present in the queue then terminate
// the thread.
if (this.irps.isEmpty())
{
this.processor = null;
synchronized (this.irps)
{
this.irps.notifyAll();
}
break;
}
// Process next IRP (if present)
irp = nextIrp;
}
// No more IRPs are present in the queue so terminate the thread.
this.processor = null;
synchronized (this.irps)
{
this.irps.notifyAll();
}
}