Swing，线程，同步，内部类，等待与唤醒综合到一起的应用... - 黑马程序员技术交流社区

package SwingThread;
import java.awt.BorderLayout;
import java.awt.Container;
import java.awt.EventQueue;
import java.awt.FlowLayout;
import java.awt.GridLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JSplitPane;
import javax.swing.JTextArea;
public class SwingThreadScXf extends JFrame {
// 主方法主要启动一个窗体
public static void main(String[] args) {
EventQueue.invokeLater(new Runnable() {
public void run() {
new SwingThreadScXf().setVisible(true);
}
});
}
// 下面这些组件因为要被线程访问，所以将它们作为成员变量，方便内部类调用。
private JTextArea text_1 = new JTextArea(30, 50);
private JTextArea text_2 = new JTextArea(30, 5);
private JButton button_1 = new JButton("开始生产");
private JButton button_2 = new JButton("开始消费");
private JButton button_3 = new JButton("停止所有线程");
// 构造方法用于生成窗体以及各组件在窗体中的摆放位置。
public SwingThreadScXf() {
super();
setBounds(100, 100, 500, 300);
setLayout(new BorderLayout());
setTitle("在Swing中演示生产者与消费者线程实例");
Container container = getContentPane();
JScrollPane scroll_Pane = new JScrollPane(text_1);
JScrollPane scrol2_Pane = new JScrollPane(text_2);
JPanel panel_left = new JPanel(new GridLayout(2, 1, 0, 0));
JPanel panel_right = new JPanel(new GridLayout(2, 1, 0, 0));
panel_left.add(new JLabel("生产者线程"));
panel_left.add(scroll_Pane);
panel_right.add(new JLabel("消费者线程"));
panel_right.add(scrol2_Pane);
JSplitPane hsplit = new JSplitPane(JSplitPane.HORIZONTAL_SPLIT,
panel_left, panel_right);
hsplit.setDividerLocation(0.5); // 设置了分隔条所在的位置，为什么不成功呢？想要分隔条在分割面板的中间。
container.add(hsplit, BorderLayout.CENTER);
// 为按钮添加事件管理器
button_1.addActionListener(new ActionListener() {
public void actionPerformed(ActionEvent e) {
do_button_1_start();
}
});
button_2.addActionListener(new ActionListener() {
public void actionPerformed(ActionEvent e) {
do_button_2_start();
}
});
button_3.addActionListener(new ActionListener() {
public void actionPerformed(ActionEvent e) {
do_close();
}
});
JPanel panel = new JPanel(new FlowLayout(FlowLayout.CENTER));
panel.add(button_1);
panel.add(button_2);
panel.add(button_3);
container.add(panel, BorderLayout.SOUTH);
}
private Computer computer = new Computer();
private Xf xfz = new Xf(computer);
private Sc scz = new Sc(computer);
Thread t1 = new Thread(scz);
Thread t2 = new Thread(xfz);
protected void do_close() { // 关闭相应的启动线程，应等待到少执行一个循环。
if (t1.isAlive()) {
scz.isstart = false;
/*if (!t1.interrupted()) { // 测试生产线程是否忆中断，若没中断则中断它。
t1.interrupt();
}*/ //启动它会发生 java.lang.StackOverflowError
}
if (t1.isAlive()) {
xfz.isstart = false;
/*if (!t1.interrupted()) { // 测试消费线程是否忆中断，若没中断则中断它。
t1.interrupt();
}*/
}
// 启用它会发生：java.lang.IllegalThreadStateException
// try{Thread.sleep(2000);}catch(Exception e){}//等待线程到少执行了一次循环。
}
// 事件处理方法，启动线程或关闭线程
protected void do_button_2_start() {
if (!t2.isAlive()) { // 判断线程是否启动，没启动的话启动。
openflag(); // 每一次启动前都要对线程标启动的标记进行设置。
t2.start();
} else { // 如果已启动，则关闭它并递归。
do_close();
do_button_2_start();
}
}
private void openflag() {// 重设线程启动的标记为可以启。
scz.isstart = true;
xfz.isstart = true;
}
protected void do_button_1_start() {
if (!t1.isAlive()) { // 判断线程是否启动，没启动的话启动。
openflag(); // 每一次启动前都要对线程标启记的标志进行设置。
t1.start();
} else { // 如果已启动，则关闭它并递。
do_close(); // 关闭了标志位，并不等于关上了生产线程，因为生产线程的第一次任务还没结束。
// 后面的递归等于一个线程启动两次，这是线程不允许的。
//try {Thread.sleep(2000);} catch (Exception e) {}// java.lang.IllegalThreadStateException
do_button_1_start();
}
}
class Computer {
private String name = "商品";
private int i = 0;
private Computer() {
}
private boolean flag = false;
public synchronized void sc() {
if (flag) {
try {super.wait();} catch (InterruptedException e) {}
}
try {
Thread.sleep(2000);
} catch (Exception e) {
}
;
this.name = "商品" + (++i);
text_1.setText("生产" + this.name + "\r\n");
this.flag = true;
super.notify();
}
public synchronized void xf() {
if (!flag) {
try {super.wait();} catch (InterruptedException e) {}// 消费及搬运时间5秒
}
try {
Thread.sleep(2000);
} catch (Exception e) {
}
text_1.setText(""); // 将产品搬走了
text_2.setText("消费" + this.name + "\r\n");
this.flag = false;
super.notify();
}
}
class Sc implements Runnable {
private Computer computer;
public Sc(Computer computer) {
this.computer = computer;
}
boolean isstart = false;// 线程启动标志
public void run() {
while (isstart) {
computer.sc();
}
}
}
class Xf implements Runnable {
private Computer computer;
public Xf(Computer computer) {
this.computer = computer;
}
boolean isstart = false;// 线程启动标志
public void run() {
while (isstart) {
computer.xf();
}
}
}
}

复制代码