added notify and interrupt in SpScPipe
Showing
- src/main/java/teetime/framework/AbstractInterThreadPipe.java 6 additions, 0 deletionssrc/main/java/teetime/framework/AbstractInterThreadPipe.java
- src/main/java/teetime/framework/AbstractStage.java 3 additions, 2 deletionssrc/main/java/teetime/framework/AbstractStage.java
- src/main/java/teetime/framework/Analysis.java 3 additions, 0 deletionssrc/main/java/teetime/framework/Analysis.java
- src/main/java/teetime/framework/RunnableConsumerStage.java 2 additions, 2 deletionssrc/main/java/teetime/framework/RunnableConsumerStage.java
- src/main/java/teetime/framework/Stage.java 12 additions, 0 deletionssrc/main/java/teetime/framework/Stage.java
- src/main/java/teetime/framework/pipe/PipeFactoryLoader.java 1 addition, 1 deletionsrc/main/java/teetime/framework/pipe/PipeFactoryLoader.java
- src/main/java/teetime/framework/pipe/SpScPipe.java 8 additions, 0 deletionssrc/main/java/teetime/framework/pipe/SpScPipe.java
- src/main/java/teetime/stage/io/EveryXthPrinter.java 5 additions, 0 deletionssrc/main/java/teetime/stage/io/EveryXthPrinter.java
- src/performancetest/java/teetime/examples/experiment15/MethodCallThroughputAnalysis15.java 17 additions, 9 deletions...examples/experiment15/MethodCallThroughputAnalysis15.java
- src/performancetest/java/teetime/examples/experiment16/MethodCallThroughputAnalysis16.java 23 additions, 10 deletions...examples/experiment16/MethodCallThroughputAnalysis16.java
- src/performancetest/java/teetime/framework/OldPipeline.java 15 additions, 0 deletionssrc/performancetest/java/teetime/framework/OldPipeline.java
- src/test/java/teetime/framework/pipe/SpScPipeTest.java 1 addition, 1 deletionsrc/test/java/teetime/framework/pipe/SpScPipeTest.java
Loading
Please register or sign in to comment