2

我想创建公平锁，以便每个线程一个接一个地获得锁，而不管优先级如何。

import java.util.concurrent.locks.ReentrantLock;

public class StarvationRunnable implements Runnable {

    private ReentrantLock lock = new ReentrantLock(true);

    public void doLongTask() {
        lock.lock();
        // to imitate long running task in critical section
        for (int i = 0; i < 1000000000; i++)
            ;
        System.out.println(Thread.currentThread().getName() + " is running with priority "
                + Thread.currentThread().getPriority() + " !");
        lock.unlock();
    }

    @Override
    public void run() {
        for (;;) {
            doLongTask();
        }
    }

    public static void main(String[] args) {
        StarvationRunnable runnable = new StarvationRunnable();

        for (int i = 0; i < 4; i++) {
            Thread thread = new Thread(runnable);
            thread.setPriority(i == 3 ? Thread.MIN_PRIORITY : Thread.MAX_PRIORITY);
            thread.start();
        }
    }
}

所以我有4个线程。3 具有最高优先级，1 具有最低优先级。我通过创建公平锁

new ReentrantLock(true);

当我运行这个演示时，它不会让具有最小优先级的线程执行与具有最大优先级的线程一样多的执行次数。但我认为公平锁就是为了这个。

如何正确使用公平锁？

4

2 回答 2

10

公平与线程优先级无关。javadoc说：

此类的构造函数接受一个可选的公平参数。当设置为 true 时，在争用情况下，锁有利于授予对等待时间最长的线程的访问权限。

另一方面，线程优先级是对本机线程调度程序的提示，以便在高优先级线程竞争获取 CPU 时间时为高优先级线程提供比低优先级线程更多的 CPU 时间。

于 2014-05-19T06:21:40.677 回答
0

我使用 javawait()和notify()框架创建了一个示例实现。无论线程优先级如何，它都提供基于先到先服务 (FCFS) 的锁。

您可以在https://github.com/nenapu/JavaLocks查看 Fair 锁实现

于 2017-01-23T18:56:01.387 回答