Java多线程运行探幽

2022/3/30 22:19:33

编程Tag： 线程运行 Java 多线程 content put consumer Producer 探幽

本文主要是介绍Java多线程运行探幽，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

事关Training2中Task4,想看看经典的两个进程并行会是什么样子

题目概述

实现简单的生产者-消费者模型：

Tray托盘容量为1；托盘满时不能放入，空时不能取货
Producer生产者共需生产10个货物；每生产一个货物后会立刻尝试放入，放入成功前不会继续生产，货物按照从1-10编号；成功放入货物后需要休息0-100ms
Consumer消费者共需消费10个货物；只能在托盘中取货。

输出：

Producer放入货物时输出： "Producer put:" + 货物编号
Consumer取出货物时输出： "Consumer get:" + 货物编号

基本代码

为了精确定轨当前代码运行位置，在多出放置System.out.println()并表上颜色；

为了方便将10改成3

public class Task4 {
    public static Tray TRAY = new Tray();
    public static void main(String[] args) {
        Thread producer = new Producer();
        Thread consumer = new Thread(new Consumer());
        producer.start();
        System.out.println("\033[32m" + "==== Depart ====" + "\033[0m");
        consumer.start();
    }
}

class Tray {
    private int content;
    private boolean full;

    Tray() {
        content = 0;
        full = false;
    }

    public synchronized void put(int content) {
        while (full) {
            try {
                System.out.println("\t[Producer] nowhere for content " + content + "! wait for get...");
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        this.content = content;
        this.full = true;
        System.out.println("Producer put:" + content);
        notifyAll();
    }

    public synchronized void get() {
        while (!full) {
            try {
                System.out.println("\t[Consumer] Nothing in tray! wait for put...");
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        this.full = false;
        System.out.println("Consumer get:" + content);
        notifyAll();
    }
}

class Producer extends Thread {
    public void run() {
        for (int i = 1; i <= 3; ++i) {
            /*(1)行*/System.out.println("\033[32m" + "Start putting " + i + "\033[m");
            Task4.TRAY.put(i);
            try {
                System.out.println("\033[32m" + "Put finished! sleep for a while..." + "\033[m");
                sleep((int) (Math.random() * 100));
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("\033[32m" + "[switch to next]" + "\033[m");
        }
    }

}

class Consumer extends Thread {
    public void run() {
        for (int i = 1; i <= 3; ++i) {
            /*(2)行*/System.out.println("\033[31m" + "Start Getting" + "\033[0m");
            Task4.TRAY.get();
            System.out.println("\033[31m" + "Get finished!\n[switch to next]" + "\033[0m");
        }
    }
}

结果、证实与猜想

start()只是启动该线程（变为Runnable状态），运行与否以及运行多少均未知（看操作系统调度？），打印depart显然不能划分两个线程的先后
不要尝试去规划多线程运行的具体情况。根据代码不同，编译后乃至运行时的顺序会变；（不知是那一层的原因，什么编译优化、运行优化啥啥不懂）（相同代码生成的程序反复运行，结果一样，不过这也可能是在相邻的时间段内，运行环境一样）

对打印语句进行调整，看运行顺序：