zoukankan      html  css  js  c++  java
  • JAVA_线程间流的通信

    package com.kk.review;

    import java.io.IOException;
    import java.io.PipedInputStream;
    import java.io.PipedOutputStream;

    public class PipedStream {
    public static void main(String[] args) {
    try{
    PipedInputStream pis=new PipedInputStream();
    PipedOutputStream pos=new PipedOutputStream();
    pis.connect(pos);
    new Producer(pos).start();
    new Consumer(pis).start();
    }catch(IOException ioe){
    ioe.printStackTrace();
    }

    }
    }

    class Producer extends Thread {
    PipedOutputStream pos;

    public Producer(PipedOutputStream pos) {
    this.pos = pos;
    }

    public void run(){
    try{
    pos.write("hello".getBytes());
    pos.close();
    }catch(IOException ioe){
    ioe.printStackTrace();
    }
    }
    }

    class Consumer extends Thread{
    PipedInputStream pis;
    public Consumer(PipedInputStream pis) {
    this.pis=pis;
    }
    public void run(){
    try{
    byte []buf=new byte[100];
    int len=pis.read(buf);
    String str=new String(buf,0,len);
    System.out.println(str);
    pis.close();
    }catch(IOException ioe){
    ioe.printStackTrace();
    }
    }
    }



  • 相关阅读:
    ububtu 14.04 问题集合
    ubuntu grub 引导修复
    Ubuntu 下 glpk 的安装及使用
    ubuntu vim 7.4 编译安装
    ubuntu 12.04 clang 3.4 安装
    CMakeLists实战解读--YouCompleteMe
    Flume安装及部署
    SpringBoot整合kafka
    linux安装kafka
    Linux安装zookeeper
  • 原文地址:https://www.cnblogs.com/BigIdiot/p/2281973.html
Copyright © 2011-2022 走看看