Searched refs:_semaphores (Results 1 – 1 of 1) sorted by relevance
37 private final ConcurrentMap<Thread, Semaphore> _semaphores; field in DNSStatefulObject.DNSStatefulObjectSemaphore46 _semaphores = new ConcurrentHashMap<Thread, Semaphore>(50); in DNSStatefulObjectSemaphore()57 Semaphore semaphore = _semaphores.get(thread); in waitForEvent()61 _semaphores.putIfAbsent(thread, semaphore); in waitForEvent()63 semaphore = _semaphores.get(thread); in waitForEvent()75 Collection<Semaphore> semaphores = _semaphores.values(); in signalEvent()87 if (_semaphores.size() == 0) { in toString()91 for (Thread thread : _semaphores.keySet()) { in toString()95 aLog.append(_semaphores.get(thread)); in toString()