MCPcopy Create free account

hub / github.com/Viscent/javamtp / functions

Functions527 in github.com/Viscent/javamtp

⨍ Functions 527◇ Types & classes 162
↓ 1 callersMethodsetExpiry
(long expiry)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/MMSDeliverRequest.java:41
↓ 1 callersMethodsetExtraInfo
(String extraInfo)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/AlarmInfo.java:41
↓ 1 callersMethodsetInstance
将当前MMSCRouter的实例更新为指定的新实例 @param newInstance 新的MMSCRouter实例
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch3/immutableobject/MMSCRouter.java:63
↓ 1 callersMethodsetIsToShutdown
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/ThreadPoolPipeDecorator.java:123
↓ 1 callersMethodsetSenderAddress
(String senderAddress)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/MMSDeliverRequest.java:73
↓ 1 callersMethodsetSubject
(String subject)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/MMSDeliverRequest.java:97
↓ 1 callersMethodsetTimeStamp
(Date timeStamp)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/MMSDeliverRequest.java:49
↓ 1 callersMethodsetToShutdown
(boolean toShutdown)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch5/tpt/TerminationToken.java:47
↓ 1 callersMethodsetTransactionID
(String transactionID)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/MMSDeliverRequest.java:57
↓ 1 callersMethodsetTransactionId
(Integer transactionId)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch10/tss/example/ImplicitParameterPassing.java:69
↓ 1 callersMethodshutdown
停止Slave实例对外提供的服务
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/SlaveSpec.java:47
↓ 1 callersMethodshutdown
(long timeout, TimeUnit unit)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/SimplePipeline.java:52
↓ 1 callersMethodshutdown
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/AlarmMgr.java:72
↓ 1 callersMethodsubmit
(String task)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch1/WorkerThread.java:61
↓ 1 callersMethodterminate
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch5/tpt/AbstractTerminatableThread.java:114
↓ 1 callersMethodtest
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/Client.java:31
↓ 1 callersMethodtest
(final String message)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch9/threadpool/example/ThreadPoolDeadLockAvoidance.java:39
↓ 1 callersMethodtestConnection
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/AlarmAgent.java:154
↓ 1 callersMethodtoString
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/Record.java:141
↓ 1 callersMethodtoString
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch5/tpt/example/AlarmType.java:25
↓ 1 callersMethodunzip
(String zipFile, String targetDir)
JavaConcurrencyPatternInAction/src/io/github/viscent/util/Tools.java:223
↓ 1 callersMethoduploadFiles
(FTPUploader ftpClientUtil)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch6/promise/example/DataSyncTask.java:76
↓ 1 callersMethodxGuarededMethod
(final String message)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch4/gs/example/NestedMonitorLockoutExample.java:77
↓ 1 callersMethodxStateChanged
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch4/gs/example/NestedMonitorLockoutExample.java:95
MethodAbstractMaster
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/AbstractMaster.java:38
MethodAbstractParallelPipe
(BlockingQueue<IN> queue, ExecutorService executorService)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/AbstractParallelPipe.java:40
MethodAbstractRequestFactory
(Map<String, Integer> respDelayConf, int maxRequestPerTimeslice)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/testdatagen/AbstractRequestFactory.java:45
MethodAbstractSerializer
(BlockingQueue<Runnable> workQueue, TaskProcessor<T, V> taskProcessor)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch11/stc/AbstractSerializer.java:32
MethodAbstractTerminatableThread
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch5/tpt/AbstractTerminatableThread.java:34
MethodAlarmInfo
(String id, AlarmType type)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/AlarmInfo.java:23
MethodAlarmMgr
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/AlarmMgr.java:33
MethodAlarmSendingThread
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/AlarmSendingThread.java:40
MethodAlarmType
(String name)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch5/tpt/example/AlarmType.java:21
MethodAsyncRequestPersistence
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/AsyncRequestPersistence.java:51
MethodAsyncTask
(Executor executor)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/AsyncTask.java:63
MethodBlockingQueueChannel
(BlockingQueue<P> queue)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch7/pc/BlockingQueueChannel.java:29
MethodChargingRequestFactory
(Map<String, Integer> respDelayConf, int timestampMaxOffset)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/testdatagen/ChargingRequestFactory.java:19
MethodClientThread
(String message, BusinessService bs)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch10/tss/example/ImplicitParameterPassing.java:40
MethodConditionVarBlocker
(Lock lock)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch4/gs/ConditionVarBlocker.java:28
MethodConsumer
(TerminationToken token, BlockingDeque<String> workQueue)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch7/pc/exmaple/WorkStealingExample.java:91
MethodContext
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch10/tss/example/ImplicitParameterPassing.java:61
MethodDataSyncTask
(Properties config)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/DataSyncTask.java:46
MethodDataSyncTask
(Map<String, String> taskParameters)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch6/promise/example/DataSyncTask.java:29
MethodDbRecordSource
(Properties config)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/DbRecordSource.java:15
MethodDelegatingTerminatableThread
(Runnable task)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch5/tpt/DelegatingTerminatableThread.java:6
MethodDispatchInvocationHandler
(Object delegate, ExecutorService executorService)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/ActiveObjectProxy.java:57
MethodFTPClientUtil
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/FTPClientUtil.java:62
MethodFakeRecordSource
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/CaseRunner.java:63
MethodFakeWorkerThread
(String outputDir, String ftpServer, String userName, String password, String servWorkingDir)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch11/stc/example/FakeWorkerThread.java:10
MethodFileTransferTask
(Future<FTPUploader> ftpUtilHodler, File file2Transfer)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/FileTransferTask.java:13
MethodGuardedAction
(Predicate guard)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch4/gs/GuardedAction.java:21
MethodHelper
(String message)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch1/JavaThreadAnywhere.java:28
MethodHelper
(String message)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch1/JavaThreadCreationAndRun.java:36
MethodImmutableLocation
(double x, double y)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch3/immutableobject/example/ImmutableLocation.java:20
MethodLabel
(String name)
JavaConcurrencyPatternInAction/src/io/github/viscent/util/Debug.java:33
MethodLocation
(double x, double y)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch3/immutableobject/example/Location.java:20
MethodLocationRequestFactory
(Map<String, Integer> respDelayConf, int timestampMaxOffset)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/testdatagen/LocationRequestFactory.java:20
MethodLogger
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/testdatagen/Logger.java:37
MethodMMSCInfo
(String deviceID, String url, int maxAttachmentSizeInBytes)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch3/immutableobject/MMSCInfo.java:35
MethodMMSCRouter
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch3/immutableobject/MMSCRouter.java:29
MethodMMSDeliverRequest
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/MMSDeliverRequest.java:37
MethodMaster
(String logFileBaseDir, String excludedOperationNames, String includedOperationNames,
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/TPSStat.java:87
MethodMessageFileDownloader
(String outputDir, final String ftpServer, final String userName, final String password,
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch11/stc/example/MessageFileDownloader.java:29
MethodPipeException
(Pipe<?, ?> sourcePipe, Object input, String message)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/PipeException.java:28
MethodPipeInitTask
(PipeContext ctx, List<Pipe<?, ?>> pipes)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/SimplePipeline.java:113
MethodPrimeGenerator
(BlockingQueue<Runnable> taskQueue)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/ParallelPrimeGenerator.java:164
MethodPrimeGeneratorService
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/ParallelPrimeGenerator.java:74
MethodRange
(int lowerBound, int upperBound)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/ParallelPrimeGenerator.java:52
MethodRecordSaveTask
(Record[] records, int targetFileIndex)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/RecordSaveTask.java:8
MethodRecordWriter
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/RecordWriter.java:58
MethodRequestSender
(int n)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/CaseRunner.java:68
MethodRetryInfo
(T subTask, Callable<V> redoCommand)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/RetryInfo.java:32
MethodSectionBasedDiskStorage
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/DiskbasedRequestPersistence.java:66
MethodSemaphoreBasedChannel
@param queue 阻塞队列，通常是一个无界阻塞队列。 @param flowLimit 流量限制数
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch7/pc/SemaphoreBasedChannel.java:38
MethodSimplePipeline
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/SimplePipeline.java:33
MethodSmsRequestFactory
(Map<String, Integer> respDelayConf, int timestampMaxOffset)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/testdatagen/SmsRequestFactory.java:20
MethodSomeService
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch11/stc/example/ReusableCodeExample.java:53
MethodSubTaskFailureException
(RetryInfo retryInfo, Exception cause)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/SubTaskFailureException.java:30
MethodTask
(String message, int id)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch11/stc/example/ReusableCodeExample.java:45
MethodTerminatableWorkerThread
(BlockingQueue<Runnable> workQueue, TaskProcessor<T, V> taskProcessor)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch11/stc/TerminatableWorkerThread.java:40
MethodTerminationToken
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/ThreadPoolPipeDecorator.java:119
MethodTerminationToken
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch5/tpt/TerminationToken.java:39
MethodThreadPoolPipeDecorator
(Pipe<IN, OUT> delegate, ExecutorService executorSerivce)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/ThreadPoolPipeDecorator.java:40
MethodThreadSpecificSecureRandom
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch10/tss/example/ThreadSpecificSecureRandom.java:46
MethodWorkStealingChannel
(BlockingDeque<T>[] managedQueues)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch7/pc/WorkStealingChannel.java:23
MethodWorkStealingExample
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch7/pc/exmaple/WorkStealingExample.java:35
MethodWorker
(ConcurrentMap<String, AtomicInteger> repository, String excludedOperationNames,
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/TPSStat.java:203
MethodWorkerThread
(String outputDir, final String ftpServer, final String userName, final String password, String s
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch11/stc/example/WorkerThread.java:26
MethodWorkerThreadPipeDecorator
(Pipe<IN, OUT> delegate, int workerCount)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/WorkerThreadPipeDecorator.java:43
MethodWorkerThreadSlave
(BlockingQueue<Runnable> taskQueue)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/WorkerThreadSlave.java:37
MethodXThread
(String message)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch10/tss/example/ThreadPrivateMember.java:32
MethodaddPipe
往该Pipeline实例中添加一个Pipe实例。 @param pipe Pipe实例
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/Pipeline.java:34
MethodbroadcastAfter
执行stateOperation所指定的操作后，决定是否唤醒本Blocker所暂挂的所有线程。 @param stateOperation 更改状态的操作，其call方法的返回值为true时，该方法才会唤醒被暂挂的线程
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch4/gs/Blocker.java:46
MethodbroadcastAfter
(Callable<Boolean> stateOperation)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch4/gs/ConditionVarBlocker.java:82
MethodbuildTasks
(final File file)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/DataSyncTask.java:176
Methodcall
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/FTPClientUtil.java:72
Methodcall
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/FileTransferTask.java:19
Methodcall
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch6/promise/example/FTPUploaderPromisor.java:31
Methodcall
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/ActiveObjectProxy.java:88
Methodcall
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/CustomScheduler.java:76
← previousnext →201–300 of 527, ranked by callers