mirror/go-patterns
1
0
Fork 0
mirror of https://github.com/tmrts/go-patterns.git synced 2025-04-02 20:56:12 +03:00
Code Issues Projects Releases Wiki Activity

synchronization/read-write-lock: peer conenction router example implementation

Browse source
This commit is contained in:
geolffreym 2022-06-10 14:16:52 -06:00
parent 86986ad8b3
commit 0df091d064
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
synchronization/read-write-lock.md
View file

@ -46,7 +46,7 @@ func (r *Router) Query(socket Socket) *Peer {
// Add create new socket connection association
func (r *Router) Add(peer *Peer) {
// Lock write/read table while add operation
// Lock write table while add operation
// A blocked Lock call excludes new readers from acquiring the lock.
r.RWMutex.Lock()
defer r.RWMutex.Unlock()
@ -55,7 +55,7 @@ func (r *Router) Add(peer *Peer) {
// Delete removes a connection from router
func (r *Router) Delete(peer *Peer) {
// Lock write/read table while delete operation
// Lock write table while delete operation
// A blocked Lock call excludes new readers from acquiring the lock.
r.RWMutex.Lock()
defer r.RWMutex.Unlock()
@ -100,10 +100,10 @@ go func(r *Router){
go func(r *Router){
// ...some logic here
// reading operation 1
connection := router.Query("192.168.1.1:8080")
connection := r.Query("192.168.1.1:8080")
//... more code here
// reading operation 2
otherQuery:= router.Query("192.168.1.1:8081")
otherQuery:= r.Query("192.168.1.1:8081")
// read locks are like counters.. until counter = 0 Write can be acquired
}(router)