1

コードが正しく動作しない理由がわかりません。問題は、ReentrantLock が ThreadClass.run() でのメソッド呼び出しをロックしないことです。

ThreadClass でロックされていると想定されるメソッドのリソース クラス

public class ResourceClass {

    private int i; 

    public void setIncrement() {
        i++;
    }

    public int getIncrement() {
        return i;
    }

}

スレッドクラス

public class ThreadClass implements Runnable {

    private ResourceClass resource;
    private ReentrantLock reentrantLock = new ReentrantLock();

    ThreadClass(ResourceClass r) {
        resource = r;
    }

    public void run() {
        reentrantLock.lock();
        try {
            resource.setIncrement();
            System.out.println(resource.getIncrement());
        } finally {
            reentrantLock.unlock();
        }
    }

}

メインクラス

public class MainClass {

    public static void main(String[] args) {

        ResourceClass resource = new ResourceClass();

        Thread thread = new Thread(new ThreadClass(resource));
        thread.start();
        Thread thread2 = new Thread(new ThreadClass(resource));
        thread2.start();
        Thread thread3 = new Thread(new ThreadClass(resource));
        thread3.start();
    }

}

run() の lock で囲まれたコードは「同期」する必要があると想定されているため、Resourse オブジェクトのメソッドにアクセスできるスレッドは 1 つだけになります。実際にはそうではありません。このコードでは、2 つのスレッドが同時にメソッドにアクセスできることを意味する繰り返しの数値が返されます。本当に単純な問題であることは知っていますが、解決方法がわかりません。助けてくれてありがとう。

アップデート：

了解。このコードは問題なく動作します (setIncrement() を削除し、関連するすべてのロジックを getIncrement() に入れました)。

public int getIncrement() {
        reentrantLock.lock();
        int incrementResult = i++;
        reentrantLock.unlock();
        return incrementResult;
}
4

2 に答える 2

5

ReentrantLock同期がないことを意味するランナブルごとに新しいものを作成しています。Runnable インスタンスごとに 1 つのロックを共有する必要があります。

于 2015-03-25T15:02:00.067 に答える