MCPcopy Create free account

hub / github.com/Viscent/javamtp / functions

Functions527 in github.com/Viscent/javamtp

↓ 1 callersMethodcreateFileTransferStage
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/DataSyncTask.java:142
↓ 1 callersMethodcreateSlaves
留给子类实现。用于创建Slave参与者实例。 @return 一组Slave参与者实例。
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/AbstractMaster.java:103
↓ 1 callersMethoddecrementSectionFileCount
(String sectionName)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/DiskbasedRequestPersistence.java:112
↓ 1 callersMethoddeepCopy
(Map<String, MMSCInfo> m)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch3/immutableobject/MMSCRouter.java:67
↓ 1 callersMethoddestroy
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch10/tss/ManagedThreadLocal.java:69
↓ 1 callersMethoddispatch
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/WorkerThreadPipeDecorator.java:72
↓ 1 callersMethoddispatch
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/CustomScheduler.java:54
↓ 1 callersMethoddispatchTask
(BufferedReader fileNamesReader, Worker[] workers)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/TPSStat.java:133
↓ 1 callersMethoddoCleanup
留给子类实现。用于实现线程停止后的一些清理动作。 @param cause
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch5/tpt/AbstractTerminatableThread.java:60
↓ 1 callersMethoddoGenerate
(int overallTPS, int duration/* minutes */, Map<String, Map<String, Integer>> respDelayConf)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/testdatagen/TestingDataGen.java:85
↓ 1 callersMethoddoInBackground
留给子类实现耗时较长的任务(同步任务),由后台线程负责调用。 @param params 客户端代码调用dispatch方法时所传递的参数列表 @return 同步任务的处理结果
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/AsyncTask.java:106
↓ 1 callersMethoddoProcess
(String task)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch1/WorkerThread.java:57
↓ 1 callersMethoddoProcess
留给子类实现。用于子类实现其任务处理逻辑。 @param input 输入元素(任务) @return 任务的处理结果 @throws PipeException
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/AbstractPipe.java:57
↓ 1 callersMethoddoProcess
对指定任务进行处理。 @param task 任务 @return 任务处理结果 @throws Exception
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch11/stc/TaskProcessor.java:35
↓ 1 callersMethoddoRun
留给子类实现其线程处理逻辑。 @throws Exception
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch5/tpt/AbstractTerminatableThread.java:53
↓ 1 callersMethoddoSendAlarm
(AlarmInfo alarm)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/AlarmAgent.java:76
↓ 1 callersMethoddoSomething
(String message)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch1/JavaThreadAnywhere.java:32
↓ 1 callersMethoddoSomething
(String message)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch1/JavaThreadCreationAndRun.java:40
↓ 1 callersMethoddoSomething
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch7/pc/exmaple/WorkStealingExample.java:64
↓ 1 callersMethoddoSomething
(String message, int id)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch11/stc/example/ReusableCodeExample.java:75
↓ 1 callersMethoddoSomething
(Connection conn)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/SampleAlarmClient.java:78
↓ 1 callersMethoddoTerminiate
留给子类实现。用于执行线程停止所需的操作。
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch5/tpt/AbstractTerminatableThread.java:67
↓ 1 callersMethoddownload
(String file)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch11/stc/example/WorkerThread.java:35
↓ 1 callersMethodenqueue
(Callable<T> methodRequest)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/CustomScheduler.java:31
↓ 1 callersMethodevaluate
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch4/gs/Predicate.java:17
↓ 1 callersMethodfinishRecords
(String recordDay, int targetFileIndex)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/RecordWriter.java:152
↓ 1 callersMethodgenerate
(int overallTPS, int duration/* minutes */, Map<String, Map<String, Integer>> respDelayConf)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/testdatagen/TestingDataGen.java:75
↓ 1 callersMethodgenerateFilesFromDB
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch6/promise/example/DataSyncTask.java:67
↓ 1 callersMethodgeneratePrime
(int upperBound)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/ParallelPrimeGenerator.java:154
↓ 1 callersMethodgetConnection
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/RecordGenerator.java:97
↓ 1 callersMethodgetDueDate
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/Record.java:117
↓ 1 callersMethodgetEffectiveDate
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/Record.java:109
↓ 1 callersMethodgetExpiry
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/MMSDeliverRequest.java:33
↓ 1 callersMethodgetInstance
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/RecordWriter.java:64
↓ 1 callersMethodgetMsisdn
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/Record.java:63
↓ 1 callersMethodgetOperationType
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/Record.java:79
↓ 1 callersMethodgetPackageId
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/Record.java:55
↓ 1 callersMethodgetProductId
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/Record.java:47
↓ 1 callersMethodgetSectionName
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/DiskbasedRequestPersistence.java:129
↓ 1 callersMethodgetTimeStamp
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/MMSDeliverRequest.java:45
↓ 1 callersMethodgetTransactionId
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch10/tss/example/ImplicitParameterPassing.java:65
↓ 1 callersMethodhashCode
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/Record.java:87
↓ 1 callersMethodhello
(String msg)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/terminology/ClientThread.java:39
↓ 1 callersMethodindexFile
(File file)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch7/pc/exmaple/AttachmentProcessor.java:61
↓ 1 callersMethodinit
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch1/WorkerThread.java:53
↓ 1 callersMethodinit
(final PipeContext ctx)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/SimplePipeline.java:97
↓ 1 callersMethodinit
(String ftpServer, String userName, String password)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/FTPClientUtil.java:88
↓ 1 callersMethodinit
(String ftpServer, String ftpUserName, String password, String serverDir)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch6/promise/example/FTPUploader.java:6
↓ 1 callersMethodinit
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch7/pc/exmaple/AttachmentProcessor.java:70
↓ 1 callersMethodinitFTPClient
(String ftpServer, String userName, String password)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch11/stc/example/WorkerThread.java:44
↓ 1 callersMethodinitialValue
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch10/tss/ManagedThreadLocal.java:33
↓ 1 callersMethodinvokeParallel
以并行的方式执行一组子任务。 @param tasks 一组子任务 @return 一组可以借以获取并行任务中的各个任务的处理结果的Promise(参见第6章,Promise模式)实例。
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/AbstractParallelPipe.java:75
↓ 1 callersMethodisSrcDeviceEligible
(String sourceNE)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/TPSStat.java:290
↓ 1 callersMethodmain
(String[] args)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/TPSStat.java:40
↓ 1 callersMethodmakeDelegateMethodName
(final Method method, final Object[] arg)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/ActiveObjectProxy.java:63
↓ 1 callersMethodmakeRecordFrom
(ResultSet rs)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/DbRecordSource.java:73
↓ 1 callersMethodmakeRecordSource
(Properties config)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/DataSyncTask.java:72
↓ 1 callersMethodmakeTask
留给子类实现。用于根据指定参数生成相应的任务实例。 @param params 参数列表 @return 任务实例。用于提交给WorkerThread。
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch11/stc/AbstractSerializer.java:45
↓ 1 callersMethodnewInstance
(ExecutorService executorSerivce)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/ThreadPoolPipeDecorator.java:127
↓ 1 callersMethodnewInstance
生成一个实现指定接口的Active Object proxy实例。 对interf所定义的异步方法的调用会被转发到servant的相应doXXX方法。 @param interf 要实现的Active Object接口 @param servant Ac
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/ActiveObjectProxy.java:42
↓ 1 callersMethodnewRequest
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/testdatagen/RequestFactory.java:17
↓ 1 callersMethodnewSubTaskDispatchStrategy
用于创建子任务派发算法策略。 默认使用轮询(Round-Robin)派发算法。 @return 子任务派发算法策略实例。
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/AbstractMaster.java:94
↓ 1 callersMethodnewSubTaskFailureException
(final T subTask, Exception cause)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/WorkerThreadSlave.java:66
↓ 1 callersMethodnewTaskDivideStrategy
留给子类实现。用于创建原始任务分解算法策略。 @param params 客户端代码调用service方法时传递的参数列表
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/AbstractMaster.java:86
↓ 1 callersMethodnextChunk
返回下一个子任务。 若返回值为null,则表示无后续子任务。 @return 下一个子任务
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/TaskDivideStrategy.java:30
↓ 1 callersMethodnotifyThreadTermination
通知TerminationToken实例:共享该实例的所有可停止线程中的一个线程停止了, 以便其停止其它未被停止的线程。 @param thread 已停止的线程
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch5/tpt/TerminationToken.java:61
↓ 1 callersMethodof
(Runnable task)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch5/tpt/DelegatingTerminatableThread.java:15
↓ 1 callersMethodonConnected
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/AlarmAgent.java:105
↓ 1 callersMethodonDisconnected
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/AlarmAgent.java:120
↓ 1 callersMethodonPostExecute
留给子类实现。用于实现同步任务执行结束后所需执行的操作。 默认实现什么也不做。 @param result 同步任务的处理结果
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/AsyncTask.java:91
↓ 1 callersMethodonPreExecute
留给子类实现耗时较短的任务,默认实现什么也不做。 @param params 客户端代码调用dispatch方法时所传递的参数列表
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/AsyncTask.java:81
↓ 1 callersMethodparseCsv
(String line)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/Record.java:125
↓ 1 callersMethodparseRequest
(InputStream reqInputStream)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/MMSDeliveryServlet.java:59
↓ 1 callersMethodprintLogs
(Logger logger)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/example/testdatagen/SimulatedRequest.java:17
↓ 1 callersMethodprocess
(T input)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/SimplePipeline.java:89
↓ 1 callersMethodprocess
(String arg, int i)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/SampleActiveObject.java:19
↓ 1 callersMethodprocessRecords
(RecordSource recordSource, Pipeline<RecordSaveTask, String> pipeline)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/DataSyncTask.java:252
↓ 1 callersMethodpurgeDir
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/RecordWriter.java:183
↓ 1 callersMethodqryRecords
(Connection dbConn)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/DbRecordSource.java:55
↓ 1 callersMethodreconnect
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/AlarmAgent.java:160
↓ 1 callersMethodregister
(Terminatable thread)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch5/tpt/TerminationToken.java:51
↓ 1 callersMethodremoveSection
(String sectionName)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/DiskbasedRequestPersistence.java:119
↓ 1 callersMethodretrieveDBConnection
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/SampleAlarmClient.java:70
↓ 1 callersMethodretrieveFTPServConf
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/DataSyncTask.java:240
↓ 1 callersMethodretrieveGeneratedFiles
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch6/promise/example/DataSyncTask.java:88
↓ 1 callersMethodretrieveRouteMapFromDB
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch3/immutableobject/MMSCRouter.java:34
↓ 1 callersMethodrun
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch1/JavaThreadAnywhere.java:38
↓ 1 callersMethodrun
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch13/pipeline/example/DataSyncTask.java:50
↓ 1 callersMethodrun
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch5/tpt/AbstractTerminatableThread.java:71
↓ 1 callersMethodrun
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/CustomScheduler.java:26
↓ 1 callersMethodrun
()
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/AlarmAgent.java:126
↓ 1 callersMethodsaveAsFile
(InputStream in, String documentId, String originalFileName)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch7/pc/exmaple/AttachmentProcessor.java:90
↓ 1 callersMethodsaveAttachment
(InputStream in, String documentId, String originalFileName)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch7/pc/exmaple/AttachmentProcessor.java:78
↓ 1 callersMethodsendAlarm
(final AlarmInfo alarmInfo)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch14/hsha/example/AlarmSendingThread.java:79
↓ 1 callersMethodsendSms
(String msisdn, String verificationCode)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch10/tss/example/SmsVerficationCodeSender.java:80
↓ 1 callersMethodservice
对子类暴露的服务方法。 该类的子类需要定义一个比该方法命名更为具体的服务方法(如downloadFileService)。 由命名含义具体的服务方法(如downloadFileService)调用该方法。 该方法使用了Template(模板)模式、Strategy(策略)模式。 @param pa
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch12/ms/AbstractMaster.java:58
↓ 1 callersMethodservice
(String message)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch10/tss/example/ImplicitParameterPassing.java:81
↓ 1 callersMethodservice
该类对外暴露的服务方法。 该类的子需要定义一个命名含义比该方法更为具体的方法(如downloadFile)。 含义具体的服务方法(如downloadFile)可直接调用该方法。 @param params 客户端代码调用该方法时所传递的参数列表 @return 可借以获取任务
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch11/stc/AbstractSerializer.java:56
↓ 1 callersMethodsetAttachment
(Attachment attachment)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/MMSDeliverRequest.java:89
↓ 1 callersMethodsetContent
(byte[] content)
JavaConcurrencyPatternInAction/src/io/github/viscent/mtpattern/ch8/activeobject/example/Attachment.java:36
← previousnext →101–200 of 527, ranked by callers