slice

Documentation

Index

• func Chunk[T any](slice []T, chunkSize int) [][]T
• type ThreadSafe
  • func NewThreadSafe[T any]() *ThreadSafe[T]
  • func (cs *ThreadSafe[T]) Append(item T)
  • func (cs *ThreadSafe[T]) AppendMany(item ...T)
  • func (cs *ThreadSafe[T]) Delete(index int)
  • func (cs *ThreadSafe[T]) Get(index int) (item T)
  • func (cs *ThreadSafe[T]) Items() []T
  • func (cs *ThreadSafe[T]) Len() int
  • func (cs *ThreadSafe[T]) Reset()

Functions

func Chunk

func Chunk[T any](slice []T, chunkSize int) [][]T

Chunk helps chunk a slice into equal size

Types

type ThreadSafe

type ThreadSafe[T any] struct {
	// contains filtered or unexported fields
}

ThreadSafe type that can be safely shared between goroutines.

func NewThreadSafe

func NewThreadSafe[T any]() *ThreadSafe[T]

NewThreadSafe creates a new lock-free thread-safe slice.

func (*ThreadSafe[T]) Append

func (cs *ThreadSafe[T]) Append(item T)

Append adds an item to the concurrent slice.

func (*ThreadSafe[T]) AppendMany

func (cs *ThreadSafe[T]) AppendMany(item ...T)

AppendMany adds many items to the concurrent slice

func (*ThreadSafe[T]) Delete

func (cs *ThreadSafe[T]) Delete(index int)

Delete an item from the slice

func (*ThreadSafe[T]) Get

func (cs *ThreadSafe[T]) Get(index int) (item T)

Get returns the slice item at the given index

func (*ThreadSafe[T]) Items

func (cs *ThreadSafe[T]) Items() []T

Items returns the list of items

func (*ThreadSafe[T]) Len

func (cs *ThreadSafe[T]) Len() int

Len returns the number of items

func (*ThreadSafe[T]) Reset

func (cs *ThreadSafe[T]) Reset()

Reset resets the slice