/* * Copyright (c) 2007, 2018, Oracle and/or its affiliates. All rights reserved. * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * * This code is free software; you can redistribute it and/or modify it * under the terms of the GNU General Public License version 2 only, as * published by the Free Software Foundation. * * This code is distributed in the hope that it will be useful, but WITHOUT * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License * version 2 for more details (a copy is included in the LICENSE file that * accompanied this code). * * You should have received a copy of the GNU General Public License version * 2 along with this work; if not, write to the Free Software Foundation, * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. * * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA * or visit www.oracle.com if you need additional information or have any * questions. */ package nsk.share.locks; import nsk.share.Wicket; /* * Thread class used for deadlock creation, requires instance of DeadlockLocker to created deadlock. * Objects of DeadlockedThread should not be created directly, to create deadlocked threads * use class DeadlockMaker */ public class DeadlockedThread extends Thread { private DeadlockLocker locker; private Wicket dedlockResolutionWicket = new Wicket(); // should call readyWicket.unlock() when deadlock is ready public DeadlockedThread(DeadlockLocker locker) { this.locker = locker; } public void run() { locker.lock(); // reach here if deadlock was resolved dedlockResolutionWicket.unlockAll(); // sleep if deadlock was resolved try { sleep(Long.MAX_VALUE); } catch (InterruptedException e) { // ignore } } // If it is expected that deadlock with using of this DeadlockedThread should be resolved // this method can be used for waiting this event public void waitDeadlockResolution() { // if deadlock was resolved DeadlockedThread calls dedlockResolutionWicket.unlockAll() dedlockResolutionWicket.waitFor(); } public DeadlockLocker getLocker() { return locker; } }