多线程生产者/消费者同步问题

Question

我有两个线程的问题，似乎没有正确同步。我基本上有一个布尔值名为“已占用”。当没有线程启动时，它被设置为false。但是当一个线程启动时，线程集被占用是真的，我有一个类，它有线程（run），它们调用下面的函数。

这是一个模拟银行的示例，它接收一个金额（初始余额），然后随机执行取款和存款。我的教授提到了一些关于从取款线程到存款线程的信号？这是怎么回事？在提取线程中，它应该运行到余额为2低，并等待存款线程。我该怎么做？

   package bank;

import java.util.Random;
import bank.Bank;
import java.util.concurrent.locks.ReentrantLock;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.Condition;

/**
 *
 * @author KJ4CC
 */
public class Action {

    private Lock accessLock = new ReentrantLock();
    private Condition cond = accessLock.newCondition();
    //private Condition withdraw  = accessLock.newCondition();


    Random rand = new Random();
    Object lock = new Object();
    Bank getBalance = new Bank();

    public void widthdrawl(int threadNum) throws InterruptedException {
        int amount = rand.nextInt(50);
            accessLock.lock();

            if (getBalance.getbalance() > amount) {

                getBalance.setBalance(getBalance.getbalance() - amount);

                System.out.println("\t\t\tThread " + threadNum + " withdrawls " + amount + "\t Balance is " + getBalance.getbalance());

            } else {

                System.out.println("\t\t\tThread " + threadNum + " Failed to withdrawl " + amount + "\t Balance is " + getBalance.getbalance());
                cond.await();

            }


            accessLock.unlock();
            Thread.sleep(rand.nextInt(5));

    }

    public void deposit(int threadNum) throws InterruptedException {
        int amount = rand.nextInt(200);
        accessLock.lock();


            getBalance.setBalance(getBalance.getbalance() + amount);
            System.out.println("Thread " + threadNum + " Deposits " + amount + "\t\t\t\t Balance is " + getBalance.getbalance());
            Thread.sleep(rand.nextInt(100));

            cond.signal();
            accessLock.unlock();


    }
}

Answer 1

首先，你必须标记你的占变量易失性。如果没有这个关键字，改变一个线程中的变量值在另一个线程中是不可见的。

第二，尝试为bank实体实现外部同步策略。这样的想法基本上是不好的：如果有人使用相同的bank而没有正确同步，它将打破内部bank状态。最好实现内部同步策略，允许银行自行保护自己的状态。

例如Bank类的API可能是这样的

class Bank {
   double synchronize getBalance() { ... }
   void synchronize deposit(double amount) { ... }
   void synchronize widthdrawl(double amount) throw BankException { ... }
}

通过此设计，内部银行状态始终保持一致，任何银行用户将等待自动完成当前银行操作。

Answer 2

您的锁定和条件使用错误。您正在调用lock（）而没有在任何地方调用unlock（），您正在调用signal（）而没有任何人调用wait（）。

有关与您的问题密切相关的示例，请参阅文档。