同时启动线程并争论全局变量

Question

我试图了解如何实现争论全局变量的线程。在我的实现中，我创建了 2 个变量，我想要 4 个线程（例如）通过递减来争议它。

第一个问题是我实现的消费方式始终遵循顺序（第一个线程减少片状冰淇淋，第二个线程减少巧克力冰淇淋）。

有什么办法可以改进这个规则吗？

我不想知道使用 CountDownLatch 的最佳位置在哪里

public class IceCream implements Runnable {

    private static int flake = 1;
    private static int chocolate = 1;
    @Override
    public void run() {
        buyIceCream();
        
    }   
    
    private void synchronized buyIceCream() {
try {
            
            if(IceCream.flake>0) {
                System.out.println("");
                System.out.println("successfully purchased " +Thread.currentThread().getName());
                Thread.sleep(200);
                IceCream.flake--;
                System.out.println("");             
            }
            else if(IceCream.chocolate>0) {
                System.out.println("");
                System.out.println("successfully purchased " +Thread.currentThread().getName());
                Thread.sleep(200);
                IceCream.chocolate--;
                System.out.println(""); 
            }
            else {
                System.out.println("No more ice cream " +Thread.currentThread().getName());
            }
        }
            catch(Exception e) {
                
            }       
        
    }
}

public static void main(String[] args) throws InterruptedException {
            IceCream c = new IceCream();
            Thread[] t = new Thread[4]; 
            for(int i = 0; i<t.length; i++) {
                t[i] = new Thread(c);
                t[i].setName("Kid"+ i);
                t[i].start();
                t[i].join();
                
            }
    
        }

Answer 1

这是一个错误：

t[i].start();
t[i].join();

join() 调用在线程结束之前不会返回，因此您的程序永远不会允许多个线程同时运行。您可以通过编写两个单独的循环来修复错误。第一个创建并启动所有线程，然后第二个连接所有线程。

for(int i = 0; i<t.length; i++) {
    t[i] = new Thread(c);
    t[i].setName("Kid"+ i);
    t[i].start();
}
for(int i = 0; i<t.length; i++) {
    t[i].join();    
}

---

这是另一个错误：

public void run() {
    buyIceCream();
}   
    
private void synchronized buyIceCream() {
    ...
}

将线程执行的所有操作包装在单个 synchronized 方法中是确保不允许两个线程同时运行的另一种方法。

至少，您应该从 synchronized 块中删除 sleep() 调用：

private void buyIceCream() {
    String message = "No more ice cream ";
    synchronized (this) {
        if(IceCream.flake>0) {
            IceCream.flake--;
            message = "Ice cream flake purchased by" + Thread.currentThread().getName();
        }
        else if(IceCream.chocolate>0) {
            IceCream.chocolate--;
            message = "Chocolate ice cream purchased by" + Thread.currentThread().getName();
        }
    }
    System.out.println(message);
    try {
        Thread.sleep(200);
    }
    catch(Exception e) {
        System.out.println("Never, EVER, completely ignore an exception.");
    }       
}

我还移动了 System.out.println()从 synchronized 块中调用，因为我知道任何单个调用打印的字符都不会与来自不同线程的单个调用打印的字符交错。 （请参阅https://stackoverflow.com/a/9459743/801894）