Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ResourceSemaphore ¶
type ResourceSemaphore[T any] struct { // contains filtered or unexported fields }
ResourceSemaphore manages concurrent access to resources by limiting the number of active operations using a semaphore.
func New ¶
func New[T any](concurrency int, fn func() T) ResourceSemaphore[T]
func (ResourceSemaphore[T]) GetBlocking ¶
func (s ResourceSemaphore[T]) GetBlocking() T
func (ResourceSemaphore[T]) Put ¶
func (s ResourceSemaphore[T]) Put()
Source Files
Click to show internal directories.
Click to hide internal directories.