frame1.java~44~

java灵感设计

package comm;

import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
import java.io.*;
public class Frame1 extends JFrame {
  JPanel contentPane;
  Button button1 = new Button();
  TextArea textArea1 = new TextArea();
  PipedInputStream in= null;
  PipedOutputStream out = null;

  //Construct the frame
  public Frame1() {
    enableEvents(AWTEvent.WINDOW_EVENT_MASK);
    try {
      jbInit();
    }
    catch(Exception e) {
      e.printStackTrace();
    }
  }
  //Component initialization
  private void jbInit() throws Exception  {
    //setIconImage(Toolkit.getDefaultToolkit().createImage(Frame1.class.getResource("[Your Icon]")));
    contentPane = (JPanel) this.getContentPane();
    button1.setLabel("线程通信");
    button1.setBounds(new Rectangle(111, 229, 150, 36));
    button1.addActionListener(new java.awt.event.ActionListener() {
      public void actionPerformed(ActionEvent e) {
        button1_actionPerformed(e);
      }
    });
    contentPane.setLayout(null);
    this.setSize(new Dimension(400, 300));
    this.setTitle("线程通信");

    textArea1.setBounds(new Rectangle(58, 35, 278, 165));
    contentPane.add(textArea1, null);
    contentPane.add(button1, null);
   in= new PipedInputStream();
   out = new PipedOutputStream(in);

  }
  //Overridden so we can exit when window is closed
  protected void processWindowEvent(WindowEvent e) {
    super.processWindowEvent(e);
    if (e.getID() == WindowEvent.WINDOW_CLOSING) {
      System.exit(0);
    }
  }

  class Sender implements Runnable
  {
  OutputStream out;
  public Sender(OutputStream out)
  {
  this.out=out;
  }
  //发送数据
  public void run()
  {
  byte value;
  try
  {
  for(int i=0;i<5;i++)
  {
  value=(byte)(Math.random()*256);
  textArea1.append("发送线程将要发送:"+value+"...\n");
  out.write(value);
  textArea1.append("数据已经发送.\n");
  Thread.sleep((long)(Math.random()*1000));
  }
  out.close();
  //管道使用完毕需要关闭
  }
  catch(Exception e)
  {
  e.printStackTrace();
  }
  }
  }
  class Receiver implements Runnable
  {
  InputStream in;
  public Receiver(InputStream in)
  {
  this.in=in;
  }
  public void run()
  {
  int value;
  try{
  while((value=in.read())!=-1)
  //管道中无数据
  {
  textArea1.append("接收线程收到:"+(byte)value+"\n");
  }
  textArea1.append("管道已经关闭.\n");
  }
  catch(Exception e)
  {
  e.printStackTrace();
  }
  }
  }

  void button1_actionPerformed(ActionEvent e) {

    Sender send =new Sender(out);
    Thread thread_s=new Thread(send);
    Receiver receive= new Receiver(in);
    Thread thread_r=new Thread(receive);
    thread_s.start();
    thread_r.start();
    try{
    thread_r.join();
    }
    catch(Exception f)
    {
    f.printStackTrace();
    }
  }
  }