java的管道流，两个线程，输出流输出数据，输入流就是不读取

线程启动要调start方法, 你调run方法相当于只有一个主线程, 因此输出一部分数据后线程就被就阻塞了, 所以只要将

主要从事网页设计、PC网站建设（电脑版网站建设）、wap网站建设（手机版网站建设）、成都响应式网站建设公司、程序开发、微网站、重庆小程序开发公司等，凭借多年来在互联网的打拼，我们在互联网网站建设行业积累了丰富的成都网站设计、成都网站建设、网络营销经验，集策划、开发、设计、营销、管理等多方位专业化运作于一体，具备承接不同规模与类型的建设项目的能力。

new Thread(ts).run();

new Thread(tr).run();

改成

new Thread(ts).start();

new Thread(tr).start();

就行了

java 中的管道流是怎么用的?它与不同的输入输出流的区别在哪里?

在Java的IO流中有一种很非凡的流就是管道流类：PipedInputStream PipedOutputStream.这两个类的实例对象必须要通过connect方法连接.

其实看这么一个程序就知道了管道流类的使用方法．

//sender.java

import java.io.*;

import java.util.*;

public class sender extends Thread

{

PipedOutputStream out = new PipedOutputStream();

public PipedOutputStream getOut()

{

return out;

}

public void run()

{

String str = "Hello,receiver ! I`m sender\n";

try

{

out.write(str.getBytes());

out.close();

}

catch(Exception e)

{

e.printStackTrace();

}

}

}

//receiver.java

import java.io.*;

import java.util.*;

public class receiver extends Thread

{

PipedInputStream in = new PipedInputStream();

public PipedInputStream getIn()

{

return in;

}

public void run()

{

byte [] buf = new byte[1024];

try

{

int len = in.read(buf);

System.out.println("the following is from sender:\n"+new String(buf,0,len));

in.close();

}catch(Exception e)

{

e.printStackTrace();

}

}

}

//TestPiped.java

import java.io.*;

class TestPiped

{

public static void main(String [] args)

{

sender s = new sender();

receiver r = new receiver();

PipedOutputStream out = s.getOut();

PipedInputStream in = r.getIn();

try

{

in.connect(out);

s.start();

r.start();

}

catch(Exception e)

{

e.printStackTrace();

}

}

}

这个程序的功能是sender发送”Hello,receiver ! I`m sender”给receiver然后receiver接受后显示出来并且在前面加上”the following is from sender”的信息．要注重的就是PipedInputStream和PipedOutputStream分别用两个线程传送数据．

java代码每一句的注释

import java.awt.*;   //awt的图形包

import javax.swing.*;//swing的图形包

import java.io.*; //IO流处理包

import java.awt.event.*; //事件处理包

public class CDInfor extends JFrame implements ActionListener//继承swing 的Frame 实现 事件接口 

{

BufferedReader in;  //输入输出管道流

FileWriter out;

JPanel jPanel1 = new JPanel(); //定义 6个Jpanel(容器)用来装组件 （就是你按钮什么的）

JPanel jPanel2 = new JPanel(new GridLayout(4,1)); //其中这个是  用网格的布局管理器

JPanel jPanel3 = new JPanel();

JPanel jPanel5 = new JPanel();

JPanel jPanel4 = new JPanel();

JPanel jPanel6 = new JPanel();

JScrollPane jScrollPane1 = new JScrollPane(); //定义滚动条

JTextArea jTextArea1 = new JTextArea("",10,25); //定义输入框

GridLayout gridLayout1 = new GridLayout(); //整体用的事 网格布局管理器

JTextField jTextField1 = new JTextField(10);  //文本输入框

JTextField jTextField2 = new JTextField(10); 

JTextField jTextField3 = new JTextField(10); 

JLabel jLabel1 = new JLabel("唱片编号："); //定义显示的字 （只用来显示字）

JLabel jLabel2 = new JLabel("唱片名称：");

JLabel jLabel3 = new JLabel("歌手姓名：");

JButton jButton1 = new JButton("增加"); //定义按钮

JButton jButton2 = new JButton("取消");

String str;

public CDInfor() { //构造方法 程序启动的时候 或者调用这个类的时候执行（这里是程序启动）

try {

setDefaultCloseOperation(EXIT_ON_CLOSE);    //天剑程序关闭的方法 要不然 你点关闭 界面没了 但是资源没释放

jbInit(); //调用jbInit（）方法 用于实现事件

}

catch (Exception exception) { //错误捕捉

exception.printStackTrace();

}

}

public void jbInit()

{

Container cp = getContentPane(); //定义一个pane的容器

cp.setLayout(new BorderLayout()); //布局为边框布局

jButton1.addActionListener(this); //将按钮1 绑定事件

jButton2.addActionListener(this); //将按钮2 绑定事件

jTextArea1.setEditable(false); //将这个输入框设定为不可编辑

jScrollPane1.getViewport().add(jTextArea1); //滚动条和jTextArea1绑定

jPanel3.add(jLabel1); jPanel3.add(jTextField1);   //将各个组件加入Jpanel里

jPanel4.add(jLabel2); jPanel4.add(jTextField2);

jPanel5.add(jLabel3); jPanel5.add(jTextField3);

jPanel6.add(jButton1); jPanel6.add(jButton2);

jPanel1.add(jScrollPane1);

jPanel2.add(jPanel3); jPanel2.add(jPanel4); jPanel2.add(jPanel5); jPanel2.add(jPanel6);

jPanel2.setPreferredSize(new Dimension(10, 150));

cp.add("Center",jPanel1);

cp.add("South",jPanel2);   

}

public void actionPerformed(ActionEvent e) //实现事件监听

{

if(e.getSource()==jButton1) //如果当前是 按钮一的话

{

try {} 

catch (Exception ex) {}

}

jTextField1.setText("");  //内容全部清空

jTextField2.setText("");

jTextField3.setText("");

}

public static void main(String[] args) throws Exception

{

CDInfor kk = new CDInfor(); //应为main是Static 所以 要new 本身类

kk.setSize(350,350); //设定大小

kk.setTitle("Please caculat:"); //设定标题栏文字

kk.setVisible(true); //是否显示 这个窗口

}

}

还不够详细么亲~ 采纳吧~~

java关于管道流的问题

首先需要明确一点的是管道流本身就不建议在一个线程中使用，这是因为向输出流中写的数据，都会存到输入流内部的一个1024字节大小的数组中，如果写的内容超过这个数组的大小，而且没有被输入流读取的话，输出流所在的线程就会等待，这时，如果是在同一个线程中，该线程就会死锁，这是sun在管道流中明确指明的，不推荐在同一个线程中使用。

至于你说的多个线程通过管道向另外一个线程发送数据，出现部分数据丢失的情况，没有代码不好分析具体原因。

大概看了下你的代码，撇开其他的问题先不管，在你的代码中所有ThrFindIndex中的PipedOutputStream都是connect到同一个PipedInputStream，而每个ThrFindIndex的run方法在运行完以后就会把这个PipedOutputStream进行close()，假设一个情景：第一个ThrFindIndex线程一直在运行，当他运行完了之后，这个PipedOutputStream就会被关闭，所有的管道也就都没用了，这必然会影响到其他使用该管道的线程。so我没有往下在看了，大致原因应该在这里。

分享文章：管道流java代码 常见管道流 java
文章位置：http://azwzsj.com/article/docpied.html