MCPcopy Create free account

hub / github.com/Viscent/javamtp / types & classes

Types & classes162 in github.com/Viscent/javamtp

ClassAbstractMaster
Master-Slave模式Master参与者的可复用实现。 @author Viscent Huang @param <T> 子任务对象类型 @param <V> 子任务的处理结果类型 @param <R> 原始任务处理结果类型
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/AbstractMaster.java:32
ClassAbstractParallelPipe
支持并行处理的Pipe实现类。 该类对其每个输入元素生成一组子任务,并以并行的方式去执行这些子任务。 各个子任务的执行结果会被合并为相应输入元素的输出结果。 @author Viscent Huang @param <IN> 输入类型 @param <OUT>
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/AbstractParallelPipe.java:36
ClassAbstractPipe
Pipe的抽象实现类。 该类会调用其子类实现的doProcess方法对输入元素进行处理。并将相应的输出作为 下一个Pipe实例的输入。 @author Viscent Huang @param <IN> 输入类型 @param <OUT> 输出类型
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/AbstractPipe.java:28
ClassAbstractRequestFactory
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/testdatagen/AbstractRequestFactory.java:21
ClassAbstractSerializer
Serial Thread Confinement模式Serializer参与者可复用实现。 @author Viscent Huang @param <T> Serializer向WorkerThread所提交的任务对应的类型 @param <V>
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch11/stc/AbstractSerializer.java:29
ClassAbstractTerminatableThread
可停止的抽象线程。 模式角色:Two-phaseTermination.AbstractTerminatableThread @author Viscent Huang
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch5/tpt/AbstractTerminatableThread.java:25
ClassActiveObjectProxy
Active Object模式的Proxy参与者的可复用实现。 模式角色:ActiveObject.Proxy @author Viscent Huang
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/ActiveObjectProxy.java:29
ClassAlarmAgent
负责连接告警服务器,并发送告警信息至告警服务器
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/AlarmAgent.java:31
ClassAlarmInfo
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/AlarmInfo.java:18
ClassAlarmMgr
告警功能入口类。 模式角色:HalfSync/HalfAsync.AsyncTask 模式角色:Two-phaseTermination.ThreadOwner
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/AlarmMgr.java:23
ClassAlarmSendingThread
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/AlarmSendingThread.java:30
EnumAlarmType
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch5/tpt/example/AlarmType.java:16
ClassAppWrapper
JavaConcurrencyPatternInAction/src/io/github/viscent/util/AppWrapper.java:25
ClassAsyncRequestPersistence
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/AsyncRequestPersistence.java:30
ClassAsyncTask
Half-sync/Half-async模式的可复用实现。 @author Viscent Huang @param <V> 同步任务的处理结果类型
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/AsyncTask.java:37
ClassAttachment
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/Attachment.java:19
ClassAttachmentProcessor
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch7/pc/exmaple/AttachmentProcessor.java:31
InterfaceBlocker
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch4/gs/Blocker.java:18
ClassBlockingQueueChannel
基于阻塞队列的通道实现。 @author Viscent Huang @param <P> “产品”类型
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch7/pc/BlockingQueueChannel.java:26
ClassBusinessService
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch10/tss/example/ImplicitParameterPassing.java:79
ClassCaseRunner
@author Viscent Huang
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/CaseRunner.java:31
ClassCaseRunner
运行以下类可以生成该程序所需的数据库记录: io.github.viscent.mtpattern.ch13.pipeline.example.RecordGenerator @author Viscent Huang
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/CaseRunner.java:32
ClassCaseRunner
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch6/promise/example/CaseRunner.java:19
ClassCaseRunner
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/CaseRunner.java:30
ClassCaseRunner
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch7/pc/exmaple/CaseRunner.java:22
ClassCaseRunner
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/CaseRunner.java:18
InterfaceChannel
对通道参与者进行抽象。 @author Viscent Huang @param <P> “产品”类型
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch7/pc/Channel.java:24
ClassChargingRequestFactory
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/testdatagen/ChargingRequestFactory.java:18
ClassClient
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/Client.java:25
ClassClientThread
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/terminology/ClientThread.java:16
ClassClientThread
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch10/tss/example/ImplicitParameterPassing.java:35
ClassConditionVarBlocker
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch4/gs/ConditionVarBlocker.java:23
ClassConfig
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/Config.java:16
ClassConnectingTask
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/AlarmAgent.java:125
ClassConsumer
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch5/tpt/example/SomeService.java:41
ClassConsumer
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch7/pc/exmaple/WorkStealingExample.java:88
ClassContext
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch10/tss/example/ImplicitParameterPassing.java:53
ClassCounter
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch10/tss/example/memoryleak/Counter.java:16
ClassCustomScheduler
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/CustomScheduler.java:22
ClassCustomThread
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch1/ThreadCreationViaSubclass.java:24
ClassDataSyncTask
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/DataSyncTask.java:43
ClassDataSyncTask
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch6/promise/example/DataSyncTask.java:26
ClassDbRecordSource
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/DbRecordSource.java:12
ClassDebug
JavaConcurrencyPatternInAction/src/io/github/viscent/util/Debug.java:19
ClassDelegatingTerminatableThread
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch5/tpt/DelegatingTerminatableThread.java:3
ClassDiskbasedRequestPersistence
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/DiskbasedRequestPersistence.java:33
ClassDispatchInvocationHandler
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/ActiveObjectProxy.java:53
ClassExceptionHandlingExample
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/ExceptionHandlingExample.java:25
ClassFTPClientUtil
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/FTPClientUtil.java:38
ClassFTPClientUtil
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch6/promise/example/FTPClientUtil.java:31
InterfaceFTPUploader
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch6/promise/example/FTPUploader.java:5
ClassFTPUploaderPromisor
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch6/promise/example/FTPUploaderPromisor.java:9
ClassFakeFTPUploader
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch6/promise/example/FakeFTPUploader.java:8
ClassFakeRecordSource
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/CaseRunner.java:60
ClassFakeWorkerThread
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch11/stc/example/FakeWorkerThread.java:8
ClassFileTransferTask
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/FileTransferTask.java:9
ClassGuardedAction
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch4/gs/GuardedAction.java:18
ClassHeartbeatTask
心跳定时任务:定时检查与告警服务器的连接是否正常,发现连接异常后自动重新连接
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/AlarmAgent.java:140
ClassHelper
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch1/WorkerThread.java:30
ClassHelper
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch1/JavaThreadAnywhere.java:25
ClassHelper
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch1/JavaThreadCreationAndRun.java:33
ClassHelper
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/terminology/ClientThread.java:37
ClassHelper
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch10/tss/example/ManagedThreadLocalClient.java:40
ClassHelper
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch4/gs/example/NestedMonitorLockoutExample.java:64
ClassIOIntensiveTask
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch9/threadpool/example/ThreadPoolSize4IOIntensiveTask.java:42
ClassImmutableLocation
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch3/immutableobject/example/ImmutableLocation.java:16
ClassImplicitParameterPassing
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch10/tss/example/ImplicitParameterPassing.java:20
ClassInstanceHolder
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/AsyncRequestPersistence.java:45
ClassJavaThreadAnywhere
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch1/JavaThreadAnywhere.java:16
ClassJavaThreadCreationAndRun
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch1/JavaThreadCreationAndRun.java:16
EnumLabel
JavaConcurrencyPatternInAction/src/io/github/viscent/util/Debug.java:28
ClassLocation
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch3/immutableobject/example/Location.java:16
ClassLocationRequestFactory
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/testdatagen/LocationRequestFactory.java:18
ClassLogEntry
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/testdatagen/LogEntry.java:16
ClassLogger
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/testdatagen/Logger.java:24
ClassMMSCInfo
彩信中心信息 模式角色:ImmutableObject.ImmutableObject
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch3/immutableobject/MMSCInfo.java:21
ClassMMSCRouter
彩信中心路由规则管理器 模式角色:ImmutableObject.ImmutableObject
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch3/immutableobject/MMSCRouter.java:23
ClassMMSDeliverRequest
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/MMSDeliverRequest.java:20
ClassMMSDeliveryServlet
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/MMSDeliveryServlet.java:27
ClassManagedThreadLocal
能够避免内存泄漏的ThreadLocal子类。 @author Viscent Huang @param <T> 相应的线程特有对象类型
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch10/tss/ManagedThreadLocal.java:27
ClassManagedThreadLocalClient
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch10/tss/example/ManagedThreadLocalClient.java:20
ClassMaster
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/TPSStat.java:75
ClassMemoryLeakPreventingServlet
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch10/tss/example/memoryleak/MemoryLeakPreventingServlet.java:31
ClassMemoryLeakingServlet
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch10/tss/example/memoryleak/MemoryLeakingServlet.java:25
ClassMemoryPseudoLeakingServlet
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch10/tss/example/memoryleak/MemoryPseudoLeakingServlet.java:26
ClassMessageFileDownloader
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch11/stc/example/MessageFileDownloader.java:24
ClassNestedMonitorLockoutExample
本程序是为了演示“嵌套监视器锁死“而写的,因此本程序需要通过手工终止进程才能结束。 @author Viscent Huang
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch4/gs/example/NestedMonitorLockoutExample.java:32
ClassNonThreadSafeCounter
非线程安全的计数器。 @author Viscent Huang
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch1/NonThreadSafeCounter.java:22
ClassOMCAgent
与运维中心(Operation and Maintenance Center)对接的类<BR> 模式角色:ImmutableObject.Manipulator
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch3/immutableobject/OMCAgent.java:20
ClassParallelPrimeGenerator
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/ParallelPrimeGenerator.java:34
InterfacePipe
对处理阶段的抽象。 负责对其输入进行处理,并将其输出作为下一个处理阶段的输入。 @author Viscent Huang @param <IN> 输入类型 @param <OUT> 输出类型
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/Pipe.java:28
InterfacePipeContext
对各个处理阶段的计算环境进行抽象,主要用于异常处理。 @author Viscent Huang
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/PipeContext.java:22
ClassPipeException
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/PipeException.java:16
ClassPipeInitTask
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/SimplePipeline.java:109
InterfacePipeline
对复合Pipe的抽象。 一个Pipeline实例可包含多个Pipe实例。 @author Viscent Huang @param <IN> 输入类型 @param <OUT> 输出类型
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/Pipeline.java:26
InterfacePredicate
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch4/gs/Predicate.java:16
ClassPrimeGenerator
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/ParallelPrimeGenerator.java:161
ClassPrimeGeneratorService
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/ParallelPrimeGenerator.java:71
ClassProducer
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch5/tpt/example/SomeService.java:30
ClassProducer
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch7/pc/exmaple/WorkStealingExample.java:77
next →1–100 of 162, ranked by callers