@@ -80,11 +80,11 @@ } if (thread.reference != null && thread.reference == weakReference) { nonNullRefCount++; } } - if (nonNullRefCount != 1) { + if (nonNullRefCount > 1) { throw new RuntimeException("more than one references were removed from queue"); } } public void run() {