deadlockthread.java

Java的面向对象数据库系统的源代码

// You can redistribute this software and/or modify it under the terms of
// the Ozone Core License version 1 published by ozone-db.org.
//
// The original code and portions created by SMB are
// Copyright (C) 1997-@year@ by SMB GmbH. All rights reserved.
//
// $Id: DeadlockThread.java,v 1.3.2.2 2003/12/21 16:01:23 per_nyfelt Exp $

package org.ozoneDB.core;


public class DeadlockThread extends Thread {

    protected TransactionManager tm;

    protected long sleepTime;

    private volatile boolean stopRunning;

    public DeadlockThread( long _sleepTime, TransactionManager _tm ) {
        sleepTime = _sleepTime;
        tm = _tm;
    }

    public final void stopRunning() {
        stopRunning = true;

        /* since tn.checkDeadlocks() does not do any i/o with possible blocking
         * there is no danger in interrupting this thread
         */
        interrupt();
    }
        

    public void run() {
        for (stopRunning = false; !stopRunning; ) {
            tm.checkDeadlocks();
            try {
                sleep(sleepTime);
            } catch (InterruptedException ignore) {
            }
        }
    }
}