Wake:Wake是一个事件驱动的框架，基于SEDA，Click，Akka和Rx的思想
需积分: 10 58 浏览量
2021-05-23
22:19:16
上传
评论
收藏 241KB ZIP 举报
Wake:Wake是一个事件驱动的框架，基于SEDA，Click，Akka和Rx的思想 （212个子文件） 
.gitattributes 138B .gitignore 141B RemoteManagerTest.java 17KB SkipListTest.java 14KB NettyMessagingTransport.java 12KB WakeProfiler.java 11KB RemoteTest.java 9KB DefaultRemoteManagerImplementation.java 9KB RuntimeClock.java 8KB ThreadPoolStage.java 7KB OrderedRemoteReceiverStage.java 7KB ThreadPoolStageTest.java 7KB ForkPoolStageTest.java 7KB MergingEventHandlerTest.java 7KB SmallMessagesTest.java 6KB ChunkedReadWriteHandler.java 6KB ClockTest.java 6KB RxThreadPoolStage.java 6KB HandlerContainer.java 5KB RemoteSenderEventHandler.java 5KB BlockingEventHandlerTest.java 5KB RxThreadPoolStageTest.java 5KB TransportTest.java 5KB TimerStage.java 4KB LargeMsgTest.java 4KB SingleThreadStage.java 4KB WakeSharedPool.java 4KB BlockingSignalEventHandlerTest.java 4KB CombinerStage.java 4KB TestCombiner.java 4KB MergingEventHandler.java 4KB TimeoutSubjectTest.java 4KB RemoteEvent.java 4KB NetUtils.java 4KB Clock.java 4KB AbstractNettyEventListener.java 4KB Meter.java 3KB SyncStageTest.java 3KB NettyChannelHandler.java 3KB TransportRaceTest.java 3KB PubSubEventHandler.java 3KB RemoteManager.java 3KB PubSubThreadPoolStageTest.java 3KB RemoteReceiverStage.java 3KB ForkPoolStage.java 3KB ProxyEventHandler.java 3KB Pull2Push.java 3KB DefaultIdentifierFactory.java 3KB RemoteSenderStage.java 3KB NonBlockingJoin.java 3KB NettyLink.java 3KB SyncStage.java 3KB DefaultThreadFactory.java 3KB RemoteIdentifierFactoryTest.java 3KB BlockingEventHandler.java 3KB SocketRemoteIdentifier.java 3KB Vertex.java 3KB RemoteConfiguration.java 3KB IndependentIterationsThreadPoolStage.java 2KB RxSyncStage.java 2KB TransportEvent.java 2KB TestRemote.java 2KB Transport.java 2KB StageManager.java 2KB TimeoutSubject.java 2KB IndependentIterationsThreadPoolStageTest.java 2KB TimerStageTest.java 2KB StageConfiguration.java 2KB MultiCodec.java 2KB UniformHistogram.java 2KB BlockingJoin.java 2KB NettyServerEventListener.java 2KB MultiDecoder.java 2KB ObjectSerializableCodec.java 2KB AbstractEStage.java 2KB WakeConfiguration.java 2KB AbstractRxStage.java 2KB RemoteEventEncoder.java 2KB RxTest.java 2KB MultiEncoder.java 2KB NettyChannelInitializer.java 2KB EWMA.java 2KB RemoteEventDecoder.java 2KB NettyClientEventListener.java 2KB RemoteReceiverEventHandler.java 2KB SimpleSubject.java 2KB BlockingSignalEventHandler.java 2KB SequentialFileReader.java 2KB MultiEventHandler.java 2KB RemoteEventCodec.java 2KB Identifier.java 2KB TupleSource.java 2KB IdentifierParser.java 2KB TestEventCodec.java 2KB DefaultRemoteMessage.java 1KB WakeParameters.java 1KB DefaultRemoteIdentifierFactoryImplementation.java 1KB ObserverCompletedException.java 1KB Time.java 1KB Subscription.java 1KB共 212 条
- 1
- 2
- 3
资源评论
