jobqueue

package

v0.2.0-alpha Latest Latest Go to latest Published: Jul 13, 2025 License: MIT Imports: 2 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ehsanranjbar/cometdump

Links

Open Source Insights

Documentation ¶

Index ¶

func Launch[J, R any](ctx context.Context, queueSize int, workersCount int, f DoFunc[J, R]) (jobQueue chan *J, resultsChan chan JobResult[J, R], cleanup func())
type DoFunc
type JobResult

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Launch ¶

func Launch[J, R any](
	ctx context.Context,
	queueSize int,
	workersCount int,
	f DoFunc[J, R],
) (
	jobQueue chan *J,
	resultsChan chan JobResult[J, R],
	cleanup func(),
)

Launch launches arbitrary number of worker goroutines and which receive jobs from the job queue and sends the result to results channel.

Types ¶

type DoFunc ¶

type DoFunc[J, R any] func(ctx context.Context, job *J) (*R, error)

DoFunc is a function type that defines the job processing function.

type JobResult ¶

type JobResult[J, R any] struct {
	Job    *J
	Result *R
	Err    error
}

JobResult represents the result of a job processed by a worker. It contains the job, the result of the job, and any error that occurred during processing.

Source Files ¶

View all Source files

launch.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL