发送程序 :
package com.thread;
import java.io.IOException;
import java.io.PipedOutputStream;
public class Thread1 extends Thread {
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
new Thread1(new PipedOutputStream()).start();
}
PipedOutputStream pipeout;
public Thread1(PipedOutputStream pipeout)
{
this.pipeout=pipeout;
}
public void run()
{
while (true)
{
try {
System.out.println(" THis is thread1");
pipeout.write("ABCDEFGHIJKLMNOPQRSTUVWXYZ.".getBytes());
pipeout.flush();
System.out.println("发生数据");
//pipeout.close();
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
//pipeout.close();
}
}
接收线程:
package com.thread;
import java.io.IOException;
import java.io.PipedInputStream;
public class Thread2 implements Runnable {
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
new Thread(new Thread2(new PipedInputStream())).start();
}
PipedInputStream pipein;
Thread2(PipedInputStream pipein)
{
this.pipein=pipein;
}
@Override
public void run() {
// TODO Auto-generated method stub
while (true)
{
try {
System.out.println(" THis is thread2");
byte[] bytes = new byte[10];
int length = pipein.read(bytes);
System.out.println("接收:"+new String(bytes,0,length));
//Thread.sleep(10000);
Thread.sleep(0);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
//主程序
package com.thread;
import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;
public class Multi_Thread {
/**
* @param args
*/
public static void main(String[] args) {
try {
PipedOutputStream pipeout= new PipedOutputStream();
//方式一
//PipedInputStream pipein= new PipedInputStream(pipeout);
//方式二
PipedInputStream pipein= new PipedInputStream();
//方式二1
//pipeout.connect(pipein);
//方式二2
pipein.connect(pipeout);
// TODO Auto-generated method stub
Thread1 threadone=new Thread1( pipeout);
//用Runnable接口类的对象创建线程;
Thread threadtwo=new Thread(new Thread2( pipein));
threadone.start();
threadtwo.start();//strat()方法启动线程;
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
相关推荐
piped piped串口映射工具
端口映射工具。很实用的工具。有需要的请下载。无需安装,解压即可使用。Cisco,华为等主流设备,及时对于新手,也简单上手,文件体积小。适用于中小型企业网络管理员使用。
端口映射工具。很实用的工具。有需要的请下载。无需安装,解压即可使用。 华为eNSP,华三HCL国内主流设备厂家模拟器连接CRT的神器,及时对于新手,也简单上手,文件体积小。适用于中小型企业网络管理员使用。
HCL模拟器使用CRT连接,需要使用的都 端口映射工具。很实用的工具。有需要的请下载。
无需安装,解压即可使用。Cisco,华为等主流设备,及时对于新手,也简单上手,文件体积小。适用于中小型企业网络管理员使用。HCL模拟器使用CRT连接,需要使用的都 端口映射工具。很实用的工具。...
crt连接hcl设备工具
端口映射工具。很实用的工具。有需要的请下载。无需安装,解压即可使用。Cisco,华为等主流设备,及时对于新手,也简单上手,文件体积小。适用于中小型企业网络管理员使用。
知道下这个的基本都知道用途了,我就不多说!
可配合HCL使用CRT登录设备。
Java中的PipedWriter、PipedReader类管道的读写依赖于PipedOutputStream、PipedInputStream两个管道输入输出类,这里我们将来举例讲解Java中Piped管道输入输出流的线程通信控制:
使用SecureCRT连接H3C Cloud Lab模拟器的中间件,很方便。
端口映射工具。无需安装,解压可用。与适用于中小型企业网络管理员使用。HCL模拟关联用
python库。 资源全名:piped.contrib.manhole-0.1.0.tar.gz
python库。 资源全名:piped.contrib.zookeeper-0.5.1.tar.gz
管道式
flymcu串口下载工具, 轻松好用,下载方便快捷、
java-piped-streams-test 注意:所描述的错误已被报告,其状态为Won't Fix 。 有关更多信息,请参阅 。 此存储库用于演示java.io.PipedInputStream (Oracle Java 实现,存在于 1.7 和 1.8)中的错误。 这是一个最小...
这是一筐很强大的端口映射工具 全自动端口映射 可以实现内网映射外网 让我们许多的不便 变成便
端口映射工具。无需安装,体积小直接下载。与适用于中小型企业网络管理员使用。HCL模拟关联用