Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Viscent/JavaConcurrencyPattern
/ functions
Functions
124 in github.com/Viscent/JavaConcurrencyPattern
⨍
Functions
124
◇
Types & classes
34
↓ 8 callers
Method
start
()
src/io/github/viscent/mtpattern/tpt/example/ProducerConsumerStop.java:41
↓ 3 callers
Method
interrupt
()
src/io/github/viscent/mtpattern/tpt/AbstractTerminatableThread.java:54
↓ 3 callers
Method
isToShutdown
()
src/io/github/viscent/mtpattern/tpt/TerminationToken.java:10
↓ 2 callers
Method
addTo
(String msisdn)
src/vh/activeobject/MMSDeliverRequest.java:105
↓ 2 callers
Method
decrementSectionFileCount
(String sectionName)
src/vh/activeobject/DiskbasedRequestPersistence.java:100
↓ 2 callers
Method
getRecipient
()
src/vh/activeobject/MMSDeliverRequest.java:64
↓ 2 callers
Method
init
()
src/io/github/viscent/mtpattern/tpt/example/AlarmMgr.java:73
↓ 2 callers
Method
makeNewSectionDir
()
src/vh/activeobject/DiskbasedRequestPersistence.java:130
↓ 2 callers
Method
newInstance
生成一个实现指定接口的Active Object proxy实例。 对interf所定义的异步方法的调用会被装发到servant的相应doXXX方法。 @param interf 要实现的Active Object接口 @param servant Active
src/vh/activeobject/lib/ActiveObjectProxy.java:89
↓ 2 callers
Method
pendingAlarms
()
src/io/github/viscent/mtpattern/tpt/example/AlarmMgr.java:86
↓ 2 callers
Method
process
(String arg, int i)
src/vh/activeobject/lib/SampleActiveObject.java:6
↓ 2 callers
Method
sendAlarm
(AlarmType type, String id, String extraInfo)
src/io/github/viscent/mtpattern/tpt/example/AlarmMgr.java:55
↓ 2 callers
Method
setAttachment
(Attachment attachment)
src/vh/activeobject/MMSDeliverRequest.java:76
↓ 2 callers
Method
setExpiry
(long expiry)
src/vh/activeobject/MMSDeliverRequest.java:28
↓ 2 callers
Method
setSenderAddress
(String senderAddress)
src/vh/activeobject/MMSDeliverRequest.java:60
↓ 2 callers
Method
setSubject
(String subject)
src/vh/activeobject/MMSDeliverRequest.java:84
↓ 2 callers
Method
setTimeStamp
(Date timeStamp)
src/vh/activeobject/MMSDeliverRequest.java:36
↓ 2 callers
Method
setTransactionID
(String transactionID)
src/vh/activeobject/MMSDeliverRequest.java:44
↓ 2 callers
Method
store
(MMSDeliverRequest request)
src/vh/activeobject/RequestPersistence.java:6
↓ 2 callers
Method
terminate
()
src/io/github/viscent/mtpattern/tpt/AbstractTerminatableThread.java:59
↓ 2 callers
Method
terminate
()
src/io/github/viscent/mtpattern/tpt/Terminatable.java:4
↓ 1 callers
Method
apply4Filename
(MMSDeliverRequest request)
src/vh/activeobject/DiskbasedRequestPersistence.java:60
↓ 1 callers
Method
deepCopy
(Map<String, MMSCInfo> m)
src/vh/immutableobject/MMSCRouter.java:55
↓ 1 callers
Method
disconnect
()
src/io/github/viscent/mtpattern/tpt/example/AlarmMgr.java:177
↓ 1 callers
Method
dispatch
()
src/vh/activeobject/CustomScheduler.java:40
↓ 1 callers
Method
doCleanup
(Exception cause)
src/io/github/viscent/mtpattern/tpt/AbstractTerminatableThread.java:23
↓ 1 callers
Method
doProcess
(String arg, int i)
src/vh/activeobject/lib/SampleActiveObjectImpl.java:5
↓ 1 callers
Method
doRun
()
src/io/github/viscent/mtpattern/tpt/AbstractTerminatableThread.java:21
↓ 1 callers
Method
doTerminiate
()
src/io/github/viscent/mtpattern/tpt/AbstractTerminatableThread.java:27
↓ 1 callers
Method
enqueue
(Callable<T> methodRequest)
src/vh/activeobject/CustomScheduler.java:17
↓ 1 callers
Method
equals
(Object obj)
src/io/github/viscent/mtpattern/tpt/example/AlarmMgr.java:128
↓ 1 callers
Method
getExpiry
()
src/vh/activeobject/MMSDeliverRequest.java:17
↓ 1 callers
Method
getInstance
()
src/io/github/viscent/mtpattern/tpt/example/AlarmMgr.java:51
↓ 1 callers
Method
getInstance
()
src/vh/activeobject/AsyncRequestPersistence.java:90
↓ 1 callers
Method
getSectionName
()
src/vh/activeobject/DiskbasedRequestPersistence.java:117
↓ 1 callers
Method
getTimeStamp
()
src/vh/activeobject/MMSDeliverRequest.java:32
↓ 1 callers
Method
invoke
(final Object proxy, final Method method, final Object[] args)
src/vh/activeobject/lib/ActiveObjectProxy.java:31
↓ 1 callers
Method
makeDelegateMethodName
(final Method method, final Object[] arg)
src/vh/activeobject/lib/ActiveObjectProxy.java:23
↓ 1 callers
Method
placeProduct
(P product)
src/io/github/viscent/mtpattern/tpt/example/ProducerConsumerStop.java:25
↓ 1 callers
Method
processResult
(String s)
src/vh/activeobject/lib/AsyncPerformanceTest.java:29
↓ 1 callers
Method
processResult
(String s)
src/vh/activeobject/lib/PerformanceTest.java:53
↓ 1 callers
Method
removeSection
(String sectionName)
src/vh/activeobject/DiskbasedRequestPersistence.java:107
↓ 1 callers
Method
retrieveRouteMapFromDB
()
src/vh/immutableobject/MMSCRouter.java:22
↓ 1 callers
Method
run
()
src/vh/activeobject/CustomScheduler.java:12
↓ 1 callers
Method
setContent
(byte[] content)
src/vh/activeobject/MMSDeliverRequest.java:132
↓ 1 callers
Method
setContentType
(String contentType)
src/vh/activeobject/MMSDeliverRequest.java:124
↓ 1 callers
Method
setExtraInfo
(String extraInfo)
src/io/github/viscent/mtpattern/tpt/example/AlarmMgr.java:115
↓ 1 callers
Method
setInstance
将当前MMSCRouter的实例更新为指定的新实例 @param newInstance 新的MMSCRouter实例
src/vh/immutableobject/MMSCRouter.java:51
↓ 1 callers
Method
setToShutdown
(boolean toShutdown)
src/io/github/viscent/mtpattern/tpt/TerminationToken.java:14
↓ 1 callers
Method
shutdown
()
src/io/github/viscent/mtpattern/tpt/example/ProducerConsumerStop.java:37
↓ 1 callers
Method
shutdown
()
src/io/github/viscent/mtpattern/tpt/example/AlarmMgr.java:77
↓ 1 callers
Method
store
(MMSDeliverRequest request)
src/vh/activeobject/DiskbasedRequestPersistence.java:25
↓ 1 callers
Method
waitUntilConnected
()
src/io/github/viscent/mtpattern/tpt/example/AlarmMgr.java:182
Method
AbstractTerminatableThread
()
src/io/github/viscent/mtpattern/tpt/AbstractTerminatableThread.java:7
Method
AlarmInfo
(String id, AlarmType type)
src/io/github/viscent/mtpattern/tpt/example/AlarmMgr.java:97
Method
AlarmMgr
()
src/io/github/viscent/mtpattern/tpt/example/AlarmMgr.java:22
Method
AsyncRequestPersistence
()
src/vh/activeobject/AsyncRequestPersistence.java:50
Method
DispatchInvocationHandler
(Object delegate, ExecutorService executorService)
src/vh/activeobject/lib/ActiveObjectProxy.java:17
Method
ImmutableLocation
(double x, double y)
src/vh/immutableobject/example/ImmutableLocation.java:7
Method
Location
(double x, double y)
src/vh/immutableobject/example/Location.java:8
Method
MMSCInfo
(String deviceID, String url, int maxAttachmentSizeInBytes)
src/vh/immutableobject/MMSCInfo.java:23
Method
MMSCRouter
()
src/vh/immutableobject/MMSCRouter.java:17
Method
MMSDeliverRequest
()
src/vh/activeobject/MMSDeliverRequest.java:24
Method
RequestSenderThread
(int chunkSize, int timeSpan)
src/vh/activeobject/Test.java:51
Method
call
()
src/vh/activeobject/CustomScheduler.java:62
Method
call
()
src/vh/activeobject/AsyncRequestPersistence.java:101
Method
call
()
src/vh/activeobject/lib/ActiveObjectProxy.java:47
Method
doCleanup
(Exception cause)
src/io/github/viscent/mtpattern/tpt/example/ProducerConsumerStop.java:57
Method
doCleanup
(Exception exp)
src/io/github/viscent/mtpattern/tpt/example/AlarmMgr.java:38
Method
doCleanup
(Exception cause)
src/io/github/viscent/mtpattern/tpt/example/TestAlarmMgrShutdown.java:32
Method
doRun
()
src/io/github/viscent/mtpattern/tpt/example/ProducerConsumerStop.java:15
Method
doRun
()
src/io/github/viscent/mtpattern/tpt/example/ProducerConsumerStop.java:52
Method
doRun
()
src/io/github/viscent/mtpattern/tpt/example/AlarmMgr.java:24
Method
doRun
()
src/io/github/viscent/mtpattern/tpt/example/TestAlarmMgrShutdown.java:26
Method
getAttachment
()
src/vh/activeobject/MMSDeliverRequest.java:72
Method
getContent
()
src/vh/activeobject/MMSDeliverRequest.java:128
Method
getContentType
()
src/vh/activeobject/MMSDeliverRequest.java:120
Method
getDeviceID
()
src/vh/immutableobject/MMSCInfo.java:35
Method
getExtraInfo
()
src/io/github/viscent/mtpattern/tpt/example/AlarmMgr.java:111
Method
getId
()
src/io/github/viscent/mtpattern/tpt/example/AlarmMgr.java:103
Method
getInstance
()
src/vh/immutableobject/MMSCRouter.java:28
Method
getMMSC
根据手机号码前缀获取对应的彩信中心信息 @param msisdnPrefix 手机号码前缀 @return 彩信中心信息
src/vh/immutableobject/MMSCRouter.java:40
Method
getMaxAttachmentSizeInBytes
()
src/vh/immutableobject/MMSCInfo.java:43
Method
getMessageType
()
src/vh/activeobject/MMSDeliverRequest.java:48
Method
getRouteMap
()
src/vh/immutableobject/MMSCRouter.java:63
Method
getSenderAddress
()
src/vh/activeobject/MMSDeliverRequest.java:56
Method
getSubject
()
src/vh/activeobject/MMSDeliverRequest.java:80
Method
getToList
()
src/vh/activeobject/MMSDeliverRequest.java:109
Method
getTransactionID
()
src/vh/activeobject/MMSDeliverRequest.java:40
Method
getUrl
()
src/vh/immutableobject/MMSCInfo.java:39
Method
getX
()
src/vh/immutableobject/example/Location.java:13
Method
getY
()
src/vh/immutableobject/example/Location.java:17
Method
hashCode
()
src/io/github/viscent/mtpattern/tpt/example/AlarmMgr.java:119
Method
init
()
src/io/github/viscent/mtpattern/tpt/example/AlarmMgr.java:172
Method
main
(String[] args)
src/vh/activeobject/CustomScheduler.java:55
Method
main
(String[] args)
src/vh/activeobject/lib/Test.java:7
Method
newThread
(Runnable r)
src/vh/activeobject/AsyncRequestPersistence.java:56
Method
run
()
src/io/github/viscent/mtpattern/tpt/AbstractTerminatableThread.java:31
Method
run
()
src/vh/activeobject/Test.java:56
Method
run
()
src/vh/activeobject/AsyncRequestPersistence.java:72
next →
1–100 of 124, ranked by callers