changed start and terminate implementation
Showing
- src/main/java/teetime/framework/AbstractInterThreadPipe.java 28 additions, 17 deletionssrc/main/java/teetime/framework/AbstractInterThreadPipe.java
- src/main/java/teetime/framework/AbstractIntraThreadPipe.java 17 additions, 0 deletionssrc/main/java/teetime/framework/AbstractIntraThreadPipe.java
- src/main/java/teetime/framework/AbstractPipe.java 4 additions, 0 deletionssrc/main/java/teetime/framework/AbstractPipe.java
- src/main/java/teetime/framework/AbstractRunnableStage.java 3 additions, 1 deletionsrc/main/java/teetime/framework/AbstractRunnableStage.java
- src/main/java/teetime/framework/CompositeStage.java 19 additions, 0 deletionssrc/main/java/teetime/framework/CompositeStage.java
- src/main/java/teetime/framework/InputPort.java 8 additions, 0 deletionssrc/main/java/teetime/framework/InputPort.java
- src/main/java/teetime/framework/OutputPort.java 5 additions, 1 deletionsrc/main/java/teetime/framework/OutputPort.java
- src/main/java/teetime/framework/RunnableConsumerStage.java 13 additions, 29 deletionssrc/main/java/teetime/framework/RunnableConsumerStage.java
- src/main/java/teetime/framework/Stage.java 8 additions, 0 deletionssrc/main/java/teetime/framework/Stage.java
- src/main/java/teetime/framework/pipe/CommittablePipe.java 0 additions, 25 deletionssrc/main/java/teetime/framework/pipe/CommittablePipe.java
- src/main/java/teetime/framework/pipe/DummyPipe.java 24 additions, 5 deletionssrc/main/java/teetime/framework/pipe/DummyPipe.java
- src/main/java/teetime/framework/pipe/IPipe.java 10 additions, 7 deletionssrc/main/java/teetime/framework/pipe/IPipe.java
- src/main/java/teetime/framework/pipe/OrderedGrowableArrayPipe.java 0 additions, 5 deletions...java/teetime/framework/pipe/OrderedGrowableArrayPipe.java
- src/main/java/teetime/framework/pipe/OrderedGrowablePipe.java 0 additions, 5 deletions...main/java/teetime/framework/pipe/OrderedGrowablePipe.java
- src/main/java/teetime/framework/pipe/RelayTestPipe.java 0 additions, 5 deletionssrc/main/java/teetime/framework/pipe/RelayTestPipe.java
- src/main/java/teetime/framework/pipe/SingleElementPipe.java 0 additions, 5 deletionssrc/main/java/teetime/framework/pipe/SingleElementPipe.java
- src/main/java/teetime/framework/pipe/SpScPipe.java 0 additions, 5 deletionssrc/main/java/teetime/framework/pipe/SpScPipe.java
- src/main/java/teetime/framework/pipe/UnboundedSpScPipe.java 0 additions, 5 deletionssrc/main/java/teetime/framework/pipe/UnboundedSpScPipe.java
- src/main/java/teetime/framework/pipe/UnorderedGrowablePipe.java 0 additions, 6 deletions...in/java/teetime/framework/pipe/UnorderedGrowablePipe.java
- src/main/java/teetime/framework/signal/ISignal.java 2 additions, 2 deletionssrc/main/java/teetime/framework/signal/ISignal.java
Loading
Please register or sign in to comment