.github
abstract-document
abstract-factory
acyclic-visitor
adapter
aggregator-microservices
ambassador
api-gateway
arrange-act-assert
async-method-invocation
balking
bridge
builder
business-delegate
bytecode
caching
callback
chain
circuit-breaker
collection-pipeline
combinator
command
commander
composite
converter
cqrs
dao
data-bus
data-locality
data-mapper
data-transfer-object
decorator
delegation
dependency-injection
dirty-flag
double-buffer
double-checked-locking
double-dispatch
eip-aggregator
eip-message-channel
eip-publish-subscribe
eip-splitter
eip-wire-tap
etc
event-aggregator
event-asynchronous
event-driven-architecture
event-queue
event-sourcing
execute-around
extension-objects
facade
factory-kit
factory-method
feature-toggle
fluentinterface
flux
flyweight
front-controller
game-loop
guarded-suspension
half-sync-half-async
hexagonal
intercepting-filter
interpreter
iterator
layers
lazy-loading
leader-election
leader-followers
marker
master-worker-pattern
etc
master-worker-pattern.urm.png
master-worker-pattern.urm.puml
src
README.md
pom.xml
mediator
memento
model-view-controller
model-view-presenter
module
monad
monostate
multiton
mute-idiom
mutex
naked-objects
null-object
object-mother
object-pool
observer
page-object
partial-response
pipeline
poison-pill
priority-queue
private-class-data
producer-consumer
promise
property
prototype
proxy
queue-load-leveling
reactor
reader-writer-lock
repository
resource-acquisition-is-initialization
retry
role-object
saga
semaphore
servant
serverless
service-layer
service-locator
sharding
singleton
spatial-partition
specification
state
step-builder
strangler
strategy
subclass-sandbox
template-method
thread-pool
throttling
tls
tolerant-reader
trampoline
twin
typeobjectpattern
unit-of-work
update-method
value-object
visitor
zh
.gitignore
CONTRIBUTING.MD
LICENSE.md
PULL_REQUEST_TEMPLATE.md
README.md
checkstyle-suppressions.xml
license-plugin-header-style.xml
pom.xml
78 lines
2.3 KiB
Plaintext
78 lines
2.3 KiB
Plaintext
![]() |
@startuml
|
||
|
package com.iluwatar.masterworker.system.systemmaster {
|
||
|
class ArrayTransposeMaster {
|
||
|
+ ArrayTransposeMaster(numOfWorkers : int)
|
||
|
~ aggregateData() : ArrayResult
|
||
|
~ setWorkers(num : int) : ArrayList<Worker>
|
||
|
}
|
||
|
abstract class Master {
|
||
|
- allResultData : Hashtable<Integer, Result<T>>
|
||
|
- expectedNumResults : int
|
||
|
- finalResult : Result<T>
|
||
|
- numOfWorkers : int
|
||
|
- workers : ArrayList<Worker>
|
||
|
~ Master(numOfWorkers : int)
|
||
|
~ aggregateData() : Result<T> {abstract}
|
||
|
- collectResult(data : Result<T>, workerId : int)
|
||
|
- divideWork(input : Input<T>)
|
||
|
+ doWork(input : Input<T>)
|
||
|
~ getAllResultData() : Hashtable<Integer, Result<T>>
|
||
|
~ getExpectedNumResults() : int
|
||
|
+ getFinalResult() : Result<T>
|
||
|
~ getWorkers() : ArrayList<Worker>
|
||
|
+ receiveData(data : Result<T>, w : Worker)
|
||
|
~ setWorkers(int) : ArrayList<Worker> {abstract}
|
||
|
}
|
||
|
}
|
||
|
package com.iluwatar.masterworker.system {
|
||
|
class ArrayTransposeMasterWorker {
|
||
|
+ ArrayTransposeMasterWorker()
|
||
|
~ setMaster(numOfWorkers : int) : Master
|
||
|
}
|
||
|
abstract class MasterWorker {
|
||
|
- master : Master
|
||
|
+ MasterWorker(numOfWorkers : int)
|
||
|
+ getResult(input : Input<T>) : Result<T>
|
||
|
~ setMaster(int) : Master {abstract}
|
||
|
}
|
||
|
}
|
||
|
package com.iluwatar.masterworker {
|
||
|
class App {
|
||
|
- LOGGER : Logger {static}
|
||
|
+ App()
|
||
|
+ main(args : String[]) {static}
|
||
|
}
|
||
|
class ArrayInput {
|
||
|
+ ArrayInput(data : int[][])
|
||
|
+ divideData(num : int) : ArrayList<Input<T>>
|
||
|
~ makeDivisions(data : int[][], num : int) : int[] {static}
|
||
|
}
|
||
|
class ArrayResult {
|
||
|
+ ArrayResult(data : int[][])
|
||
|
}
|
||
|
class ArrayUtilityMethods {
|
||
|
- LOGGER : Logger {static}
|
||
|
- RANDOM : Random {static}
|
||
|
+ ArrayUtilityMethods()
|
||
|
+ arraysSame(a1 : int[], a2 : int[]) : boolean {static}
|
||
|
+ createRandomIntMatrix(rows : int, columns : int) : int[][] {static}
|
||
|
+ matricesSame(m1 : int[][], m2 : int[][]) : boolean {static}
|
||
|
+ printMatrix(matrix : int[][]) {static}
|
||
|
}
|
||
|
abstract class Input<T> {
|
||
|
+ data : T
|
||
|
+ Input<T>(data : T)
|
||
|
+ divideData(int) : ArrayList<Input<T>> {abstract}
|
||
|
}
|
||
|
abstract class Result<T> {
|
||
|
+ data : T
|
||
|
+ Result<T>(data : T)
|
||
|
}
|
||
|
}
|
||
|
Master --> "-finalResult" Result
|
||
|
MasterWorker --> "-master" Master
|
||
|
ArrayInput --|> Input
|
||
|
ArrayResult --|> Result
|
||
|
ArrayTransposeMasterWorker --|> MasterWorker
|
||
|
ArrayTransposeMaster --|> Master
|
||
|
@enduml
|