一个java 线程互斥体

java 代码

package test;

public final class Mutex {
    private long locks;
    private Thread owner;

    public synchronized void lock() {
        Thread currentThread = Thread.currentThread();
        while (locks > 0 && currentThread != owner) {
            try {
                wait();
            } catch (InterruptedException e) {

            }
        }
        owner = currentThread;
        locks++;
    }

    public synchronized void unlock() {
        Thread currentThread = Thread.currentThread();
        if (locks == 0 && owner != currentThread) {
            return;
        }
        locks--;
        if (locks == 0) {
            owner = null;
            notifyAll();
        }
    }
}

分享到：

凹凸贴图 | 简单的Hessian demo

• 2007-11-22 10:56
• 浏览 1979
• 评论(0)
• 查看更多