Fountain

English

Tiếng Việt

English

Tiếng Việt

Appearance

Import path: gitlab.soludian.com/soludian/fountain/libs/fsync/fgo

fgo ​

go
import "gitlab.soludian.com/soludian/fountain/libs/fsync/fgo"

Index ​

Constants ​

DefaultPoolSize giới hạn tổng số background task chạy đồng thời cho default pool. Đủ lớn để không tạo back-pressure ở tải bình thường, đủ nhỏ để chặn goroutine explosion ở tải đột biến (1 service phát sinh hàng nghìn fire-and-forget tasks).

go
const DefaultPoolSize = 256

func InFlight ​

go
func InFlight() int64

InFlight trả về số task đang chạy trên default pool.

func Run ​

go
func Run(name string, fn func())

Run sử dụng default pool. Xem Pool.Run. Có thể sử dụng NewPool để tạo pool riêng nếu muốn, nhưng default pool này đủ dùng cho hầu hết các trường hợp fire-and-forget tasks đơn giản. NewPool tạo Pool mới với capacity cho trước. Có thể sử dụng "gitlab.soludian.com/soludian/fountain/libs/fsync" để có thêm tính năng như timeout, retry, v.v. nhưng ở đây implement đơn giản để tránh phụ thuộc ngoài. Ngoài ra có thể sử dụng golang.org/x/sync/semaphore nếu muốn phân chia tài nguyên theo trọng số (weighted semaphore) thay vì 1 task = 1 slot như hiện tại.

type Pool ​

Pool là một bounded worker pool dựa trên semaphore.

go
type Pool struct {
    // contains filtered or unexported fields
}

func NewPool ​

go
func NewPool(capacity int) *Pool

NewPool tạo Pool mới với capacity cho trước. Có thể sử dụng "gitlab.soludian.com/soludian/fountain/libs/fsync" để có thêm tính năng như timeout, retry, v.v. nhưng ở đây implement đơn giản để tránh phụ thuộc ngoài. Ngoài ra có thể sử dụng golang.org/x/sync/semaphore nếu muốn phân chia tài nguyên theo trọng số (weighted semaphore) thay vì 1 task = 1 slot như hiện tại.

func (*Pool) InFlight ​

go
func (p *Pool) InFlight() int64

InFlight trả về số task đang chạy. Hữu ích cho monitoring/metrics.

func (*Pool) Run ​

go
func (p *Pool) Run(name string, fn func())

Run chạy fn trong goroutine có giới hạn concurrency.

  • Nếu pool còn slot: acquire ngay, spawn goroutine, return ngay.
  • Nếu pool đầy: block caller cho tới khi có slot trống (back-pressure).
  • Recover panic để 1 task lỗi không crash service.

Tham số `name` chỉ dùng cho logging khi panic xảy ra.

Generated by gomarkdoc