`
Donald_Draper
  • 浏览: 981564 次
社区版块
存档分类
最新评论

Pipe定义

    博客分类:
  • NIO
nio 
阅读更多
Channel接口定义:http://donald-draper.iteye.com/blog/2369111
AbstractInterruptibleChannel接口定义:http://donald-draper.iteye.com/blog/2369238
SelectableChannel接口定义:http://donald-draper.iteye.com/blog/2369317
SelectionKey定义:http://donald-draper.iteye.com/blog/2369499
SelectorProvider定义:http://donald-draper.iteye.com/blog/2369615
AbstractSelectableChannel定义:http://donald-draper.iteye.com/blog/2369742
NetworkChannel接口定义:http://donald-draper.iteye.com/blog/2369773
Selector定义:http://donald-draper.iteye.com/blog/2370015
AbstractSelector定义:http://donald-draper.iteye.com/blog/2370138
SelectorImpl分析 :http://donald-draper.iteye.com/blog/2370519
WindowsSelectorImpl解析一(FdMap,PollArrayWrapper):
http://donald-draper.iteye.com/blog/2370811
WindowsSelectorImpl解析二(选择操作,通道注册,通道反注册,选择器关闭等):
http://donald-draper.iteye.com/blog/2370862
ByteChannel,分散聚集通道接口的定义(SocketChannel):
http://donald-draper.iteye.com/blog/2371065
NIO-Pipe示例:http://donald-draper.iteye.com/blog/2373535
前面一篇文章我们看了一个管道实例,今天来看一下管道的定义
package java.nio.channels;
import java.io.IOException;
import java.nio.channels.spi.*;


/**
 * A pair of channels that implements a unidirectional pipe.
 *Pipe是一对单向通道的实现
 *  A pipe consists of a pair of channels: A writable {@link
 * Pipe.SinkChannel </code>sink<code>} channel and a readable {@link
 * Pipe.SourceChannel </code>source<code>} channel.  Once some bytes are
 * written to the sink channel they can be read from source channel in exactly
 * the order in which they were written.
 *管道Pipe包括一对通道,一个可写的SinkChannel,一个可读的SourceChannel。只要有字节序列
 写到sink通道,那么source通道可以按字节写的顺序读取字节序列。
 *  Whether or not a thread writing bytes to a pipe will block until another
 * thread reads those bytes, or some previously-written bytes, from the pipe is
 * system-dependent and therefore unspecified.  Many pipe implementations will
 * buffer up to a certain number of bytes between the sink and source channels,
 * but such buffering should not be assumed.  

 *一个线程是否可以写字节序列到管道,取决于是否有其他线程从依赖于系统的管道,
 读取这些字节序列或先前已写到管道的字节序列,因此是不确定的。许多管道的实现将会
 把一定数量的字节序列在sink与source通道之前缓存起来,但这种缓存不应该assumed。
 *
 * @author Mark Reinhold
 * @author JSR-51 Expert Group
 * @since 1.4
 */

public abstract class Pipe {

    /**
     * A channel representing the readable end of a {@link Pipe}.  
     *SourceChannel表示管道的可读端
     * @since 1.4
     */
    public static abstract class SourceChannel
        extends AbstractSelectableChannel
        implements ReadableByteChannel, ScatteringByteChannel
    {
        /**
         * Constructs a new instance of this class.
         */
        protected SourceChannel(SelectorProvider provider) {
            super(provider);
        }

        /**
         * Returns an operation set identifying this channel's supported
         * operations.
         *返回通道支持的操作事件
         *  Pipe-source channels only support reading, so this method
         * returns {@link SelectionKey#OP_READ}.  

         *由于管道的Source通道只支持读操作,所以此方只返回SelectionKey#OP_READ
         * @return  The valid-operation set
         */
        public final int validOps() {
            return SelectionKey.OP_READ;
        }

    }

    /**
     * A channel representing the writable end of a {@link Pipe}.  </p>
     * SinkChannel表示管道的可写端
     * @since 1.4
     */
    public static abstract class SinkChannel
        extends AbstractSelectableChannel
        implements WritableByteChannel, GatheringByteChannel
    {
        /**
         * Initializes a new instance of this class.
         */
        protected SinkChannel(SelectorProvider provider) {
            super(provider);
        }

        /**
         * Returns an operation set identifying this channel's supported
         * operations.
         *返回通道支持的操作事件
         *  Pipe-sink channels only support writing, so this method returns
         * {@link SelectionKey#OP_WRITE}.  

         *由于管道的Sink通道只支持写操作,所以此方只返回SelectionKey#OP_WRITE
         * @return  The valid-operation set
         */
        public final int validOps() {
            return SelectionKey.OP_WRITE;
        }

    }

    /**
     * Initializes a new instance of this class.
     */
    protected Pipe() { }

    /**
     * Returns this pipe's source channel.  </p>
     *获取管道的source通道
     * @return  This pipe's source channel
     */
    public abstract SourceChannel source();

    /**
     * Returns this pipe's sink channel.  </p>
     *获取管道的sink通道
     * @return  This pipe's sink channel
     */
    public abstract SinkChannel sink();

    /**
     * Opens a pipe.
     *打开一个管道
     *  The new pipe is created by invoking the {@link
     * java.nio.channels.spi.SelectorProvider#openPipe openPipe} method of the
     * system-wide default {@link java.nio.channels.spi.SelectorProvider}
     * object.  

     *
     * @return  A new pipe
     *
     * @throws  IOException
     *          If an I/O error occurs
     */
    public static Pipe open() throws IOException {
        return SelectorProvider.provider().openPipe();
    }
}

总结:
Pipe中包含一个可写通道SinkChannel和一个可读通道SourceChannel。sink向管道写字节序序列,source从管道读取字节序列。
PipeImpl解析:http://donald-draper.iteye.com/blog/2373628
0
2
分享到:
评论

相关推荐

    PCIe物理层接口定义了物理层中的,媒介层和物理编码子层之间的统一接口.docx

    PIPE定义了媒介层(Media Access Layer,MAC)和物理编码子层(Physical Sub-layer,PCS)之间的交互规范。MAC层主要处理数据包的访问控制,而PCS则负责对数据进行编码,以便在物理介质上传输。这两个子层共同构成了...

    USB3.0 PIPE总线协议

    USB 3.0的物理接口芯片(PHY)负责执行信号的物理编码和解码,而PIPE总线协议定义了PHY与USB控制器之间的通信接口。这意味着,无论是PHY还是控制器,它们之间进行数据交换时都必须遵循PIPE总线协议的标准。 PIPE...

    PIPE4: PHY inteface for Pcie

    这一规范涉及到信号的电平、时序、接口协议、管脚定义以及信号完整性要求等多方面的内容。 PIPE4规范中还提到了诸多细节性的规定和说明,比如信号的发送和接收端的电气特性,这些参数通常包括电压水平、电流强度、...

    USB PIPE协议

    首先,了解USB和PCIE的定义对理解USB PIPE协议至关重要。USB(通用串行总线)是一种广泛应用于计算机及其外围设备间通信的标准,其目的是简化各种设备之间的通信和连接。PCIE,即PCI Express,是一种高速串行计算机...

    python pipe文档

    Pipe 的定义 在 Python pipe 中,Pipe 是一个可以被管道的函数,也就是说它可以被用作管道符号(|)的操作数。Pipe 函数可以是标准函数,也可以是使用 Pipe 类初始化的 lambda 表达式。 Pipe 的分类 Python pipe ...

    pipe接口协议

    PIPE协议定义了物理层接口的标准,确保不同设备制造商之间的兼容性,以保证数据能够在不同架构之间准确、可靠地传输。协议中还涉及到了知识产权声明,说明该规范是按原样提供的,没有任何形式的保证,包括但不限于...

    pipe4.3 petri网软件

    5. **定义变迁条件**:右键点击变迁,选择“编辑”设置变迁的触发条件。 6. **运行模拟**:完成模型构建后,选择“运行”进行动态模拟,观察系统行为。 7. **模型检查**:点击“检查”按钮,软件会自动分析模型的...

    linux内核pipe机制实现

    ### Linux内核Pipe机制实现详解 #### 一、概述与背景 在Linux内核中,管道(pipe)是一种用于进程间通信的重要机制。它允许一个进程(通常称为生产者)向管道写入数据,而另一个进程(消费者)从该管道读取数据。...

    MindShare_Intro_to_PIPE_spec.pdf

    MAC架构连接到PCI Express数据链路层逻辑,并且PIPE规范定义了PHY必须实现的标准功能,以及PHY和内部逻辑(MAC)之间标准的并行接口。 PHY/MAC接口是指 PHY层和MAC层之间的接口。PIPE规范定义了两者之间的标准交互...

    pipe4.4.1英文版协议

    PIPE4.4.1 英文版协议 PIPE4.4.1 英文版协议是 ...PIPE4.4.1 英文版协议是一份重要的技术规范,对于 PCI Express, SATA, 和 USB 3.1 架构的PHY层面规范提供了详细的定义和指导,为厂商和开发者提供了可靠的参考依据。

    Petri网建模工具pipe4.3

    用户可以添加、删除、移动位置和转换,以及设定它们之间的弧线,以定义令牌流动的规则。 除了建模功能,Pipe4.3的一大亮点是其过程挖掘特性。过程挖掘是一种数据驱动的方法,通过分析事件日志来揭示隐藏在大量事件...

    PCIe Gen1~Gen5的PIPE Interface学习文档

    在PCIe Gen1中,PIPE接口主要定义了物理层的基本结构和通信协议。每个Generation都有其特定的速率和电气特性。Gen1的传输速率为2.5 GT/s(Gigatransfers per second),每个通道(Lane)可以提供2.5 Gbps的带宽。双...

    Petri网建模软件——PIPE4.3.0

    3. **定义初始标记**:指定每个地方的初始标记数量,表示系统的起始状态。 4. **设置约束**:如果需要,可以为转换添加预条件和后效应,以限制其触发条件。 5. **进行仿真**:点击运行按钮,软件将根据模型执行仿真...

    成果导向的创新创业基础3333教学大纲和PIPE教学方案定义.pdf

    成果导向的创新创业基础3333教学大纲与PIPE教学方案是一种创新的教学模式,旨在解决高等教育中关于创新创业教育的“为什么、教什么、如何教、谁来教”的四大问题。这一模式由孙洪义教授在2017年的《创新教育研究》...

    NamePipe.zip

    - `NamePipe.h`:头文件通常包含类定义、函数声明和其他接口,供其他模块调用。在这个案例中,它可能会声明`NamePipe`类及其成员函数,如`open()`, `write()`, `read()` 和 `close()`等,以供用户在自己的代码中...

    pipe2.4 源代码

    1. **管道定义**:管道是一种半双工的数据通道,即数据只能单向流动。它由两个文件描述符组成,一个用于写入(parent end),另一个用于读取(child end)。在创建管道时,操作系统会分配一块缓冲区,用于存储待传输...

    PIPE2-V2.5

    通过定义这些元素,用户可以构建出复杂的并发行为模型。 在分析Petri网模型时,关键概念包括可达性图、安全性与活性分析、覆盖和死锁检测。可达性图展示了所有可能的系统状态,而安全性与活性分析则帮助确定系统...

    pipe flow expert 教程

    ### Pipe Flow Expert 教程知识点概述 #### 一、软件简介 - **名称**:PipeFlow Expert是一款专门用于管道系统水力分析的专业软件。 - **版本**:本教程基于PipeFlow Expert 2013版。 - **特点**:具备优秀的用户...

    Petri网分析工具PIPE

    1. **建模**:创建新的PETRI网模型,定义放置、转换以及它们之间的关系。每个放置和转换都可以带有属性,如名称、颜色和标记数量。 2. **编辑**:修改现有模型,添加或删除元素,调整网络结构。这包括改变放置和...

    Petri网建模工具PIPE2.5

    在建模过程中,用户首先绘制Petri网图,然后定义初始标记,接着通过模拟或分析来验证模型的正确性。如果发现问题,可以调整模型直至满足设计要求。 在实际操作中,对于初学者,理解Petri网的基本概念如地方(places...

Global site tag (gtag.js) - Google Analytics