moonbitstack/moonzero/threading

README
U
Balancer
U
BidiCall
U
BidiStreamFactory
U
BidiStreamHandler
U
Breaker
U
Call
U
ClientDeps
U
ClientStreamHandler
U
Clock
U
Conf
U
CorsConf
U
Discovery
U
Endpoint
U
FileEntry
U
Files
U
Group
U
Interceptor
U
Invoker
U
JwtRoute
U
Layer
U
Lease
U
LoadBalancedChannel
U
LogLevel
U
Logger
U
ManualClock
U
Mapper
U
MaxConns
U
MethodTimeout
U
Middleware
U
MiddlewaresConf
U
Once
U
PeriodLimit
U
PeriodResult
U
Pool
U
PrivateKeyConf
U
Promise
U
RedisPeriodLimit
U
RedisTokenLimit
U
Refusal
U
Refused
U
Registrar
U
RequestLog
U
Resolve
U
RestConf
U
RestEngine
U
Ring
U
RouteOptions
U
RoutineGroup
U
RpcChannel
U
RpcClientConf
U
RpcClientMiddlewaresConf
U
RpcCluster
U
RpcGroup
U
RpcHandler
U
RpcMetrics
U
RpcServer
U
RpcServerConf
U
RpcServerMiddlewaresConf
U
Server
U
ServerDeps
U
ServerMetrics
U
ServerStreamHandler
U
Service
U
ServiceConf
U
ServiceGroup
U
Shedder
U
ShutdownCoordinator
U
SignatureConf
U
SignatureInput
U
SignatureKey
U
SignatureVerifier
U
Single
U
StableRunner
U
StatConf
U
TaskRunner
U
Ticket
U
TokenBucket
U
Unavailable
U
Update
U
VerifiedContent
U
View
U
Watcher
V
auth
V
breaker
V
canonical_key
V
chain
V
chunk
V
client_breaker
V
client_duration
V
client_interceptors
V
client_prometheus
V
client_timeout
V
client_tracing
V
content_security
V
cors
V
default_latency_buckets
V
duration_key
V
entry
V
exposition_content_type
V
file_server
V
group_by
V
hold
V
jwt_authorized
V
jwt_sign
V
jwt_verify
V
layer
V
level_name
V
logging
V
logx
V
map_reduce
V
map_reduce_parallel
V
max_conns
V
maxbytes
V
media_type_of
V
message_key
V
metrics
V
metrics_handler
V
mount_metrics
V
not_allowed
V
not_found
V
period_limit
V
period_script
V
plain_text
V
port
V
rate_limit
V
recovery
V
redis_period_limit
V
redis_rate_limit
V
refusal
V
request_id
V
retry
V
retry_with_backoff
V
rpc_port
V
server_auth
V
server_breaker
V
server_interceptors
V
server_prometheus
V
server_recover
V
server_shedding
V
server_stat
V
server_timeout
V
server_tracing
V
set_log_level
V
set_log_sink
V
set_log_writer
V
shedding
V
stamp_key
V
status_code
V
status_name
V
status_of_code
V
structured_logging
V
timed_out
V
timeout
V
token_script
V
too_large
V
too_many
V
trace_clock
V
trace_id_of
V
tracer
V
tracing
V
unavailable
V
verify_signature

moonbitstack/moonzero/threading does not have a README file

RoutineGroup

pub struct RoutineGroup {
  tasks : Array[async () -> Unit]
}

A set of tasks that are started together and joined together.

Bodies are collected first and run at wait, which is what makes the group usable while the tasks they depend on are still being decided: a fan-out whose width comes from the data does not have to know that width up front.

RoutineGroup::len

source

fn RoutineGroup::len(self : RoutineGroup) -> Int

How many bodies are waiting.

RoutineGroup::new

source

fn RoutineGroup::new() -> RoutineGroup

A group with nothing in it.

RoutineGroup::run

source

fn RoutineGroup::run(self : RoutineGroup, body : async () -> Unit) -> Unit

Add a body to the group. The bodies run concurrently when wait is called.

RoutineGroup::wait

source

async fn RoutineGroup::wait(self : RoutineGroup) -> Unit

Run every body concurrently and return when all of them have finished. A body that raises cancels the others and the failure reaches the caller.

StableRunner

source

pub struct StableRunner[T] {
  queue : @moonbitlang/async/aqueue.Queue
Queue[T]
}

A runner that keeps only the newest pending item: pushing while the consumer is busy replaces what it will take next, so a burst collapses to its last value.

A service uses it for work that is idempotent and worth doing only once — a configuration reload, a cache refresh, a re-index triggered by a write.

StableRunner::close

source

fn[T] StableRunner::close(self : StableRunner[T]) -> Unit

Stop accepting work and wake the consumer so it can finish.

StableRunner::new

source

fn[T] StableRunner::new() -> StableRunner[T]

A stable runner with nothing pending. The queue holds one item and drops the oldest when a newer one arrives, so a producer never waits and never queues more than one turn of work.

StableRunner::push

source

async fn[T] StableRunner::push(self : StableRunner[T], item : T) -> Unit

Make item the pending one, replacing whatever was pending. The queue holds one item and discards the older one, so this never waits for the consumer.

StableRunner::run

source

async fn[T] StableRunner::run(self : StableRunner[T], handle : async (T) -> Unit) -> Unit

Take the pending item and hand it to handle, one at a time, until the runner is closed.

TaskRunner

source

pub struct TaskRunner[T] {
  queue : @moonbitlang/async/aqueue.Queue
Queue[T]
}

A queue drained by one consumer: push hands work over and returns, run is the loop that takes it. What a service uses when the work must not run on the request's own task — a write-behind, a slow notification.

TaskRunner::close

source

fn[T] TaskRunner::close(self : TaskRunner[T]) -> Unit

Stop accepting work and wake the consumer so it can finish.

TaskRunner::new

source

fn[T] TaskRunner::new() -> TaskRunner[T]

A runner with an unbounded queue.

TaskRunner::push

source

async fn[T] TaskRunner::push(self : TaskRunner[T], item : T) -> Unit

Hand one item to the consumer, waiting if the queue is bounded and full.

TaskRunner::run

source

async fn[T] TaskRunner::run(self : TaskRunner[T], handle : async (T) -> Unit) -> Unit

Drain the queue, handing each item to handle, until the runner is closed. A handler that raises stops the loop and the failure reaches whoever is waiting for the service.

TaskRunner::try_push

source

fn[T] TaskRunner::try_push(self : TaskRunner[T], item : T) -> Bool

Try to hand one item over without waiting; false when the queue is full or already closed.

Source Files

Install

Download zip

A service framework for MoonBit.

go-zeromicroservicemicroservicesservice-frameworkframeworkrestrpczrpcgrpcmiddlewarecircuit-breakerrate-limitload-sheddingload-balancingservice-discoverymetricstracingloggingconfigyamljwtsignaturecorsgzipssefile-serverp2csingleflightcacheredissqlprometheusopentelemetrygraceful-shutdownmoonapiservermoonbit

moonbitstack

Apache-2.0