ambidextrous/gemp-lotr
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Unblocking resources during iteration by iterating over collection copy.

Browse Source
This commit is contained in:
marcins78
2013-01-21 09:01:14 +00:00
parent f0ace146d2
commit 1d9aea30ce
1 changed files with 18 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
gemp-lotr/gemp-lotr-common/src/main/java/com/gempukku/polling/LongPollingSystem.java
View File

@@ -21,8 +21,8 @@ public class LongPollingSystem {
private ProcessingRunnable _timeoutRunnable;
private ExecutorService _executorService = new ThreadPoolExecutor(10, Integer.MAX_VALUE,
60L, TimeUnit.SECONDS,
new SynchronousQueue<Runnable>());
60L, TimeUnit.SECONDS,
new SynchronousQueue<Runnable>());
public void start() {
_timeoutRunnable = new ProcessingRunnable();
@@ -66,22 +66,26 @@ public class LongPollingSystem {
@Override
public void run() {
while (true) {
Set<ResourceWaitingRequest> resourcesCopy;
synchronized (_waitingActions) {
long now = System.currentTimeMillis();
Iterator<ResourceWaitingRequest> iterator = _waitingActions.iterator();
while (iterator.hasNext()) {
ResourceWaitingRequest waitingRequest = iterator.next();
if (waitingRequest.getLongPollingResource().wasProcessed())
iterator.remove();
else {
if (waitingRequest.getStart() + _pollingLength < now) {
waitingRequest.getLongPollableResource().deregisterRequest(waitingRequest);
iterator.remove();
execute(waitingRequest.getLongPollingResource());
}
resourcesCopy = new HashSet<ResourceWaitingRequest>(_waitingActions);
}
long now = System.currentTimeMillis();
Iterator<ResourceWaitingRequest> iterator = resourcesCopy.iterator();
while (iterator.hasNext()) {
ResourceWaitingRequest waitingRequest = iterator.next();
if (waitingRequest.getLongPollingResource().wasProcessed())
iterator.remove();
else {
if (waitingRequest.getStart() + _pollingLength < now) {
waitingRequest.getLongPollableResource().deregisterRequest(waitingRequest);
_waitingActions.remove(waitingRequest);
execute(waitingRequest.getLongPollingResource());
}
}
}
pause();
}
}