The code in TransactionReaper is using wait and notify to suspend and wake up threads contending to add and remove transaction controls and to manage transfer of expired controls between the main queue and the reaper worker queue. It should actually be calling notifyAll() since notify() only wakes up one thread and multiple threads may be queued. All occurences of calls to notify() need to be transformed to notifyAll().