文档章节

线程通信-管道

清尘V
 清尘V
发布于 2016/05/16 14:12
字数 270
阅读 36
收藏 2

通过PipedInputStream和PipedOutputStream方式可以实现线程间通信

现在看具体例子:

package com.vincent.pipe;

import java.io.PipedOutputStream;

/**
 * Vincent 创建于 2016/5/13.
 */
public class Thread1 implements Runnable {

    private PipedOutputStream outputStream;

    public Thread1( PipedOutputStream outputStream) {
        this.outputStream = outputStream;
    }

    @Override
    public void run() {
        while (true) {
            try {
                Thread.sleep(5000);
                String s = String.valueOf(System.currentTimeMillis());
                byte[] bytes = s.getBytes();
                outputStream.write(bytes);
                System.out.println("写入数据:"+s);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}
package com.vincent.pipe;

import java.io.PipedInputStream;

/**
 * Vincent 创建于 2016/5/13.
 */
public class Thread2 implements Runnable {

    private PipedInputStream inputStream;

    public Thread2(PipedInputStream inputStream) {
        this.inputStream = inputStream;

    }

    @Override
    public void run() {

        try {
            int length = -1;
            byte[] bytes = new byte[1024];
            //read方法会阻塞线程
            while ((length = inputStream.read(bytes)) != -1) {
                System.out.println("读取数据:" + new String(bytes, 0, length));
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
package com.vincent.pipe;

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

/**
 * Vincent 创建于 2016/5/13.
 */
public class Main {
    public static void main(String[] args) throws IOException {

        PipedOutputStream outputStream=new PipedOutputStream();
        PipedInputStream inputStream=new PipedInputStream();

        inputStream.connect(outputStream);

        Thread thread1=new Thread(new Thread1(outputStream));
        Thread thread2=new Thread(new Thread2(inputStream));
        thread1.start();
        thread2.start();
    }
}

输出:

写入数据:1463378999693
读取数据:1463378999693
写入数据:1463379004694
读取数据:1463379004694
写入数据:1463379009695
读取数据:1463379009695

通过以上例子,线程之间通过管道方式实现了通信

© 著作权归作者所有

共有 人打赏支持
清尘V
粉丝 42
博文 107
码字总数 47780
作品 0
青岛
程序员
Linux 的 进程/线程 通信方式总结

linux系统中的进程通信方式主要以下几种: PIPE(FIFO) 消息队列 信号量(Semaphore) 共享存储 SOCKET 同一主机上的进程通信方式 UNIX进程间通信方式: 包括管道(PIPE), 有名管道(FIFO), 和信号(...

大数据之路
2012/10/05
0
0
20.进程与线程通信方式之间的差异

进程线程通信方式之间的差异 每个进程有自己的地址空间。两个进程中的地址即使值相同,实际指向的位置也不同。进程间通信一般通过操作系统的公共区进行。 同一进程中的线程因属同一地址空间,...

u014590757
04/16
0
0
Java IO类库之管道流PipeInputStream与PipeOutputStream

一、java管道流介绍 在java多线程通信中管道通信是一种重要的通信方式,在java中我们通过配套使用管道输出流PipedOutputStream和管道输入流PipedInputStream完成线程间通信。多线程管道通信的...

老韭菜
07/23
0
1
进程间、线程间通信方式

一、进程间的通信方式 (1)管道( pipe ):管道是一种半双工的通信方式,数据只能单向流动,而且只能在具有亲缘关系的进程间使用。进程的亲缘关系通常是指父子进程关系。 (2)有名管道 (nam...

为了美好的明天
02/07
0
0
进程间通信的方式及比较

进程间通信就是在不同进程之间传播或交换信息,那么不同进程之间存在着什么双方都可以访问的介质呢?进程的用户空间是互相独立的,一般而言是不能互相访问的,唯一的例外是共享内存区。但是,...

willis_sun
2017/03/31
0
0

没有更多内容

加载失败,请刷新页面

加载更多

Cointext在阿根廷和土耳其推出比特币现金短信钱包

Cointext于10月15日开始在土耳其和阿根廷提供新的基于SMS的比特币现金钱包服务,这两个国家的加密货币使用量急剧上升,以应对严峻的经济形势。 移动钱包 通过短信处理BCH交易 “比特币是更好...

lpy411
23分钟前
1
0
大数据早课-0918

9.18日早课 1.全局搜索含有abc的文件名称或文件夹的命令 2.当前目录一般用什么表示 3.切换到上一次和上一层命令分别是什么 4.pwd是查看当前目录的什么 5.隐藏文件或文件夹的标识是什么? 怎样...

hnairdb
23分钟前
1
0
mybatis学习笔记一

一、mybaits需要的项目依赖 <!-- https://mvnrepository.com/artifact/org.mybatis/mybatis --> <dependency> <groupId>org.mybatis</groupId> <artif......

wuyiyi
24分钟前
2
0
CentOS6 安装 GraphicsMagick

1.安装相关依赖: yum install -y gcc libpng libjpeg libpng-devel libjpeg-devel ghostscript libtiff libtiff-devel freetype freetype-devel 2.下载并解压到目录/usr/local/ wget ft......

凯文加内特
26分钟前
1
0
RabbitMq集群使用Nginx做负载均衡

1.配置rabbitmq集群(可以参考前一篇RabbitMq之部署集群) 2.Nginx做负载均衡 注意:Nginx1.90版本后 新增了stream 模块用于一般的 TCP 代理和负载均衡,之前版本不支持 修改Nginx配置文件ngi...

zhaochaochao
31分钟前
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部