Skip to content
Browse files

added interrupt handling

  • Loading branch information...
1 parent 9101589 commit d83ab1d94f47c7a7f6bc0361805b1f82b727a6fa @belaban committed
Showing with 2 additions and 0 deletions.
  1. +2 −0 src/org/jgroups/blocks/locking/LockService.java
View
2 src/org/jgroups/blocks/locking/LockService.java
@@ -78,6 +78,8 @@ public boolean tryLock() {
public boolean tryLock(long time, TimeUnit unit) throws InterruptedException {
Boolean retval=(Boolean)ch.downcall(new Event(Event.LOCK, new LockInfo(name, true, true, true, time, unit)));
+ if(Thread.currentThread().isInterrupted())
+ throw new InterruptedException();
return retval.booleanValue();
}

0 comments on commit d83ab1d

Please sign in to comment.
Something went wrong with that request. Please try again.