From e6b874bb05c610f8a89c4dc28de3845750a204d1 Mon Sep 17 00:00:00 2001
From: Herwin van Welbergen <hvanwelbergen@techfak.uni-bielefeld.de>
Date: Wed, 30 Mar 2016 17:11:23 +0200
Subject: [PATCH] uses offer instead of put to avoid blocking the input buffer
handler
---
.../java/src/ipaaca/util/communication/FutureIU.java | 9 +--------
.../java/src/ipaaca/util/communication/FutureIUs.java | 2 +-
2 files changed, 2 insertions(+), 9 deletions(-)
diff --git a/ipaacalib/java/src/ipaaca/util/communication/FutureIU.java b/ipaacalib/java/src/ipaaca/util/communication/FutureIU.java
index c9130cb..1cd4854 100644
--- a/ipaacalib/java/src/ipaaca/util/communication/FutureIU.java
+++ b/ipaacalib/java/src/ipaaca/util/communication/FutureIU.java
@@ -34,14 +34,7 @@ public class FutureIU
String id = iu.getPayload().get(idKey);
if (idVal.equals(id))
{
- try
- {
- queue.put(iu);
- }
- catch (InterruptedException e)
- {
- Thread.interrupted();
- }
+ queue.offer(iu);
}
}
}, ImmutableSet.of(category));
diff --git a/ipaacalib/java/src/ipaaca/util/communication/FutureIUs.java b/ipaacalib/java/src/ipaaca/util/communication/FutureIUs.java
index f52d0fb..2e9ed3b 100644
--- a/ipaacalib/java/src/ipaaca/util/communication/FutureIUs.java
+++ b/ipaacalib/java/src/ipaaca/util/communication/FutureIUs.java
@@ -40,7 +40,7 @@ public class FutureIUs
{
String id = iu.getPayload().get(idKey);
resultsMap.putIfAbsent(id, new ArrayBlockingQueue<AbstractIU>(1));
- resultsMap.get(id).add(iu);
+ resultsMap.get(id).offer(iu);
}
}, ImmutableSet.of(category));
}
--
GitLab