确保 Java 同步锁按顺序获取？

Question

我们有两个线程通过同步方法访问一个列表。我们能否

a) 依靠运行时来确保每个人都将根据他们尝试的顺序接收对方法的访问权限，或者

b) 虚拟机是否遵循任何其他规则

c) 是否有更好的方法来序列化请求？

Answer 1

不，synchronized 将以任何顺序提供访问权限（取决于 JVM 实现）。在某些情况下，这甚至可能导致线程饥饿。

您可以使用 ReentrantLock< 来确保顺序/a> （自 Java 5.0 起）带有 fair=true 选项。 (Lock lock = new ReentrantLock(true);)

Answer 2

不，您无法确定对同步方法的两次调用是否会按顺序发生。该顺序未指定且依赖于实现。

这是在 17.1 锁 部分中定义的JLS。请注意，这没有说明等待锁的线程应该获得访问的顺序。

Answer 3

您不能依赖每个线程调用特定方法的顺序。如果只有两个线程可能是的。但想象一下，如果有 3 个线程并且 1 个线程已经获得了访问权限。其他 2 个线程在尝试访问时将等待，其中任何一个线程都可以被授予访问权限，并且这不取决于它们调用此方法的顺序。
所以，不建议依赖命令。

Answer 4

c) 有没有更好的方法来序列化请求？

您是否有机会使用列表作为队列，即使用模式是否看起来像这样？

while (some condition) {
    synchronized(theList){
        anItem = get and remove an element from theList
    }
    do some work with anItem
}

如果是这样，您可能需要查看 BlockingQueue 接口而不是使用您自己的锁定方案。实现（如 ArrayBlockingQueue）具有公平性等设置。

Answer 5

我总是将同步保留给应用程序服务器或引擎，除非定义自己的强度

Answer 6

我已经用几种仪器解决了类似的问题。我试图解决的问题是乒乓服务。两个线程，一个打印 Ping，另一个打印 Pong。但它们必须是连续的。 （没有双 Ping 或双 Pong）

我将在这里放置一个实现，但您可以查看其他实现（目前有 6 或 7 种不同的方式）
https://github.com/tugrulkarakaya/pingpong

import java.util.concurrent.*;

public class Method2CyclicBarrier {

ExecutorService service;
CyclicBarrier c1 = new CyclicBarrier(2);
CyclicBarrier c2 = new CyclicBarrier(2);

public static void main(String[] args) {
    Method2CyclicBarrier m = new Method2CyclicBarrier();
    m.runPingPong();
}

public void runPingPong(){
    service = Executors.newFixedThreadPool(2);
        service.submit(() -> this.printPing(c1, c2));
        service.submit(() -> this.printPong(c1, c2));
}



public void printPing(CyclicBarrier c1, CyclicBarrier c2) {
    while(!Thread.currentThread().isInterrupted()) {
        try {
            c1.await();
            System.out.println("PING");
            c2.await();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
        catch(BrokenBarrierException ex){

        }
    }
}

public void printPong(CyclicBarrier c1, CyclicBarrier c2){
    while(!Thread.currentThread().isInterrupted()) {
        try {
            c1.await();
            c2.await();
            System.out.println("PONG");
        } catch (InterruptedException ex) {
            Thread.currentThread().interrupt();
        } catch(BrokenBarrierException ex){

        }
    }
}
}

Answer 7

是的。

如果通过一种同步方法访问该列表，则来自多个线程的并发请求将被序列化。