.circleci
.github
.mvn
abstract-document
abstract-factory
active-object
acyclic-visitor
adapter
aggregator-microservices
ambassador
api-gateway
arrange-act-assert
async-method-invocation
balking
bridge
builder
business-delegate
bytecode
caching
callback
chain-of-responsibility
circuit-breaker
cloud-static-content-hosting
collection-pipeline
combinator
command
commander
composite
composite-entity
converter
cqrs
dao
data-bus
data-locality
data-mapper
data-transfer-object
decorator
delegation
dependency-injection
dirty-flag
domain-model
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
factory-kit
factory-method
fanout-fanin
feature-toggle
filterer
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
localization
lockable-object
marker
master-worker-pattern
mediator
memento
model-view-controller
model-view-presenter
model-view-viewmodel
module
monad
monitor
etc
src
README.md
pom.xml
monostate
multiton
mute-idiom
naked-objects
null-object
object-mother
object-pool
observer
page-object
parameter-object
partial-response
pipeline
poison-pill
presentation
priority-queue
private-class-data
producer-consumer
promise
property
prototype
proxy
queue-load-leveling
reactor
reader-writer-lock
registry
repository
resource-acquisition-is-initialization
retry
role-object
saga
separated-interface
servant
serverless
service-layer
service-locator
sharding
singleton
spatial-partition
special-case
specification
state
step-builder
strangler
strategy
subclass-sandbox
table-module
template-method
thread-pool
throttling
tls
tolerant-reader
trampoline
transaction-script
twin
typeobjectpattern
unit-of-work
update-method
value-object
version-number
visitor
.all-contributorsrc
.gitignore
CONTRIBUTING.MD
LICENSE.md
PULL_REQUEST_TEMPLATE.md
README.md
checkstyle-suppressions.xml
gpl-3.0.txt
lgpl-3.0.txt
license-plugin-header-style.xml
lombok.config
mvnw
mvnw.cmd
pom.xml
72 lines
2.3 KiB
Markdown
72 lines
2.3 KiB
Markdown
![]() |
---
|
||
|
layout: pattern
|
||
|
title: Monitor
|
||
|
folder: monitor
|
||
|
permalink: /patterns/monitor/
|
||
|
categories: Concurrency
|
||
|
language: en
|
||
|
tags:
|
||
|
- Performance
|
||
|
---
|
||
|
|
||
|
## Intent
|
||
|
Monitor pattern is used to create thread-safe objects and prevent conflicts between threads in concurrent applications.
|
||
|
|
||
|
## Explanation
|
||
|
|
||
|
In plain words
|
||
|
|
||
|
> Monitor pattern is used to enforce single-threaded access to data. Only one thread at a time is allowed to execute code within the monitor object.
|
||
|
|
||
|
Wikipedia says
|
||
|
|
||
|
> In concurrent programming (also known as parallel programming), a monitor is a synchronization construct that allows threads to have both mutual exclusion and the ability to wait (block) for a certain condition to become false. Monitors also have a mechanism for signaling other threads that their condition has been met.
|
||
|
|
||
|
**Programmatic Examples**
|
||
|
|
||
|
Consider there is a bank that transfers money from an account to another account with transfer method . it is `synchronized` mean just one thread can access to this method because if many threads access to it and transfer money from an account to another account in same time balance changed !
|
||
|
|
||
|
```
|
||
|
class Bank {
|
||
|
|
||
|
private int[] accounts;
|
||
|
Logger logger;
|
||
|
|
||
|
public Bank(int accountNum, int baseAmount, Logger logger) {
|
||
|
this.logger = logger;
|
||
|
accounts = new int[accountNum];
|
||
|
Arrays.fill(accounts, baseAmount);
|
||
|
}
|
||
|
|
||
|
public synchronized void transfer(int accountA, int accountB, int amount) {
|
||
|
if (accounts[accountA] >= amount) {
|
||
|
accounts[accountB] += amount;
|
||
|
accounts[accountA] -= amount;
|
||
|
logger.info("Transferred from account :" + accountA + " to account :" + accountB + " , amount :" + amount + " . balance :" + getBalance());
|
||
|
}
|
||
|
}
|
||
|
```
|
||
|
|
||
|
getBalance always return total amount and the total amount should be same after each transfers
|
||
|
|
||
|
```
|
||
|
private synchronized int getBalance() {
|
||
|
int balance = 0;
|
||
|
for (int account : accounts) {
|
||
|
balance += account;
|
||
|
}
|
||
|
return balance;
|
||
|
}
|
||
|
}
|
||
|
```
|
||
|
|
||
|
## Class diagram
|
||
|

|
||
|
|
||
|
## Applicability
|
||
|
Use the Monitor pattern when
|
||
|
|
||
|
* we have a shared resource and there is critical section .
|
||
|
* you want to create thread-safe objects .
|
||
|
* you want to achieve mutual exclusion in high level programming language .
|