Forgot to set the cancelled flag in cancel()
This commit is contained in:
parent
b4b0413071
commit
5b27576494
@ -398,6 +398,9 @@ public class HashedWheelTimer implements Timer {
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
cancelled = true;
|
||||||
|
|
||||||
|
// Might be called more than once, but doesn't matter.
|
||||||
synchronized (this) {
|
synchronized (this) {
|
||||||
wheel[stopIndex].remove(this);
|
wheel[stopIndex].remove(this);
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user