Compare commits
	
		
			2 Commits
		
	
	
		
			58052e8679
			...
			b9369570ae
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| b9369570ae | |||
| a7cb9b50dc | 
@ -1,77 +0,0 @@
 | 
				
			|||||||
package usync
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
import "sync"
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// Locker guards access to a value. It must not be copied after first use.
 | 
					 | 
				
			||||||
type Locker[T any] struct {
 | 
					 | 
				
			||||||
	value T
 | 
					 | 
				
			||||||
	mutex sync.Mutex
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// NewLocker creates a new locker with the specified value.
 | 
					 | 
				
			||||||
func NewLocker[T any] (value T) Locker[T] {
 | 
					 | 
				
			||||||
	return Locker[T] {
 | 
					 | 
				
			||||||
		value: value,
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// Set sets the value of the locker.
 | 
					 | 
				
			||||||
func (this *Locker[T]) Set (value T) {
 | 
					 | 
				
			||||||
	this.mutex.Lock()
 | 
					 | 
				
			||||||
	defer this.mutex.Unlock()
 | 
					 | 
				
			||||||
	this.value = value
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// Borrow borrows the value from the locker, and returns a function that must
 | 
					 | 
				
			||||||
// immediately be deferred, like this:
 | 
					 | 
				
			||||||
//
 | 
					 | 
				
			||||||
//   value, done := locker.Borrow()
 | 
					 | 
				
			||||||
//   defer done()
 | 
					 | 
				
			||||||
//
 | 
					 | 
				
			||||||
// From the time Borrow is called to the time the done function is called, it is
 | 
					 | 
				
			||||||
// safe to access the locked object from within the current goroutine.
 | 
					 | 
				
			||||||
func (this *Locker[T]) Borrow () (T, func ()) {
 | 
					 | 
				
			||||||
	this.mutex.Lock()
 | 
					 | 
				
			||||||
	return this.value, this.mutex.Unlock
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// RWLocker guards separate read/write access to a value.
 | 
					 | 
				
			||||||
type RWLocker[T any] struct {
 | 
					 | 
				
			||||||
	value T
 | 
					 | 
				
			||||||
	mutex sync.RWMutex
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// NewRWLocker creates a new locker with the specified value. It must not be
 | 
					 | 
				
			||||||
// copied after first use.
 | 
					 | 
				
			||||||
func NewRWLocker[T any] (value T) RWLocker[T] {
 | 
					 | 
				
			||||||
	return RWLocker[T] {
 | 
					 | 
				
			||||||
		value: value,
 | 
					 | 
				
			||||||
	}
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// Set sets the value of the locker.
 | 
					 | 
				
			||||||
func (this *RWLocker[T]) Set (value T) {
 | 
					 | 
				
			||||||
	this.mutex.Lock()
 | 
					 | 
				
			||||||
	defer this.mutex.Unlock()
 | 
					 | 
				
			||||||
	this.value = value
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// Borrow borrows the value from the locker for write access, and returns a
 | 
					 | 
				
			||||||
// function that must immediately be deferred, like this:
 | 
					 | 
				
			||||||
//
 | 
					 | 
				
			||||||
//   value, done := locker.Borrow()
 | 
					 | 
				
			||||||
//   defer done()
 | 
					 | 
				
			||||||
//
 | 
					 | 
				
			||||||
// From the time Borrow is called to the time the done function is called, it is
 | 
					 | 
				
			||||||
// safe to access the locked object from within the current goroutine.
 | 
					 | 
				
			||||||
func (this *RWLocker[T]) Borrow () (T, func ()) {
 | 
					 | 
				
			||||||
	this.mutex.Lock()
 | 
					 | 
				
			||||||
	return this.value, this.mutex.Unlock
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
// RBorrow is like Borrow, but returns the item for read access only. Do not
 | 
					 | 
				
			||||||
// under any circumstances write to an item returned from this method.
 | 
					 | 
				
			||||||
func (this *RWLocker[T]) RBorrow () (T, func ()) {
 | 
					 | 
				
			||||||
	this.mutex.Lock()
 | 
					 | 
				
			||||||
	return this.value, this.mutex.Unlock
 | 
					 | 
				
			||||||
}
 | 
					 | 
				
			||||||
							
								
								
									
										77
									
								
								sync/monitor.go
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										77
									
								
								sync/monitor.go
									
									
									
									
									
										Normal file
									
								
							@ -0,0 +1,77 @@
 | 
				
			|||||||
 | 
					package usync
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					import "sync"
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Monitor guards access to a value. It must not be copied after first use.
 | 
				
			||||||
 | 
					type Monitor[T any] struct {
 | 
				
			||||||
 | 
						value T
 | 
				
			||||||
 | 
						mutex sync.Mutex
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// NewMonitor creates a new Monitor with the specified value.
 | 
				
			||||||
 | 
					func NewMonitor[T any] (value T) Monitor[T] {
 | 
				
			||||||
 | 
						return Monitor[T] {
 | 
				
			||||||
 | 
							value: value,
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Set sets the value of the Monitor.
 | 
				
			||||||
 | 
					func (this *Monitor[T]) Set (value T) {
 | 
				
			||||||
 | 
						this.mutex.Lock()
 | 
				
			||||||
 | 
						defer this.mutex.Unlock()
 | 
				
			||||||
 | 
						this.value = value
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Borrow borrows the value from the Monitor, and returns a function that must
 | 
				
			||||||
 | 
					// immediately be deferred, like this:
 | 
				
			||||||
 | 
					//
 | 
				
			||||||
 | 
					//   value, done := Monitor.Borrow()
 | 
				
			||||||
 | 
					//   defer done()
 | 
				
			||||||
 | 
					//
 | 
				
			||||||
 | 
					// From the time Borrow is called to the time the done function is called, it is
 | 
				
			||||||
 | 
					// safe to access the locked object from within the current goroutine.
 | 
				
			||||||
 | 
					func (this *Monitor[T]) Borrow () (T, func ()) {
 | 
				
			||||||
 | 
						this.mutex.Lock()
 | 
				
			||||||
 | 
						return this.value, this.mutex.Unlock
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// RWMonitor guards separate read/write access to a value.
 | 
				
			||||||
 | 
					type RWMonitor[T any] struct {
 | 
				
			||||||
 | 
						value T
 | 
				
			||||||
 | 
						mutex sync.RWMutex
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// NewRWMonitor creates a new Monitor with the specified value. It must not be
 | 
				
			||||||
 | 
					// copied after first use.
 | 
				
			||||||
 | 
					func NewRWMonitor[T any] (value T) RWMonitor[T] {
 | 
				
			||||||
 | 
						return RWMonitor[T] {
 | 
				
			||||||
 | 
							value: value,
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Set sets the value of the Monitor.
 | 
				
			||||||
 | 
					func (this *RWMonitor[T]) Set (value T) {
 | 
				
			||||||
 | 
						this.mutex.Lock()
 | 
				
			||||||
 | 
						defer this.mutex.Unlock()
 | 
				
			||||||
 | 
						this.value = value
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// Borrow borrows the value from the Monitor for write access, and returns a
 | 
				
			||||||
 | 
					// function that must immediately be deferred, like this:
 | 
				
			||||||
 | 
					//
 | 
				
			||||||
 | 
					//   value, done := Monitor.Borrow()
 | 
				
			||||||
 | 
					//   defer done()
 | 
				
			||||||
 | 
					//
 | 
				
			||||||
 | 
					// From the time Borrow is called to the time the done function is called, it is
 | 
				
			||||||
 | 
					// safe to access the locked object from within the current goroutine.
 | 
				
			||||||
 | 
					func (this *RWMonitor[T]) Borrow () (T, func ()) {
 | 
				
			||||||
 | 
						this.mutex.Lock()
 | 
				
			||||||
 | 
						return this.value, this.mutex.Unlock
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					// RBorrow is like Borrow, but returns the item for read access only. Do not
 | 
				
			||||||
 | 
					// under any circumstances modify anything returned by this method.
 | 
				
			||||||
 | 
					func (this *RWMonitor[T]) RBorrow () (T, func ()) {
 | 
				
			||||||
 | 
						this.mutex.Lock()
 | 
				
			||||||
 | 
						return this.value, this.mutex.Unlock
 | 
				
			||||||
 | 
					}
 | 
				
			||||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user