首页 > 代码库 > java:管道流(线程间管道流)
java:管道流(线程间管道流)
class Send implements Runnable{ PipedOutputStream pos = null; public Send() { this.pos = new PipedOutputStream(); } public PipedOutputStream getPipedOutputStream() { return this.pos; } @Override public void run() { // TODO 自动生成的方法存根 String str = "hello world!!!"; try { this.pos.write(str.getBytes()); } catch (IOException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } try { this.pos.close(); } catch (IOException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } } } class Receive implements Runnable{ PipedInputStream pis = null; public Receive(){ this.pis = new PipedInputStream(); } public PipedInputStream getPipedInputStream() { return this.pis; } @Override public void run() { // TODO 自动生成的方法存根 byte b[] = new byte[1024]; int len = 0; try { len = this.pis.read(b); } catch (IOException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } try { this.pis.close(); } catch (IOException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } System.out.println(new String(b,0,len) ); } } public class PipedOutputStreamDemo { public static void main(String[] args) throws Exception { // TODO 自动生成的方法存根 Send send = new Send(); Receive rec = new Receive(); send.getPipedOutputStream().connect(rec.getPipedInputStream()); new Thread(send).start(); new Thread(rec).start(); } }
java:管道流(线程间管道流)
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。