corelib_concurrency

corelib_concurrency

Cooperative concurrency primitives (`Fiber`, channels) and `System.Threading` OS-thread helpers.

Piotr Mikstacki

Library

0 downloads

Score 59%

Latest 0.0.1

First publish 2026-06-05 12:06:40Z

Last publish 2026-06-05 12:06:40Z

0.0.1

Readme

corelib_concurrency

Cooperative concurrency primitives for the Beskid standard library (Fiber, channels, and related modules under System.Threading).

Depends on corelib_foundation. OS-thread helpers live in this package; the aggregate corelib prelude re-exports the supported surface.

Versions

Versions

Version	Status	Size	Published	Actions
0.0.1	Active	69.5 KB	2026-06-05 12:06:40Z

Badges

Badges & external sites

GitHub-friendly badge (SVG) and an optional iframe card. Scoped names such as @pckg/… use the package= query parameter so paths stay valid everywhere.

Badge (markdown, links to this package)

[![corelib_concurrency on Beskid registry](http://pckg.beskid-lang.org/api/embed/badge.svg?package=corelib_concurrency)](http://pckg.beskid-lang.org/packages/corelib_concurrency)

Badge (markdown, image only)

![Beskid registry](http://pckg.beskid-lang.org/api/embed/badge.svg?package=corelib_concurrency)

Widget (HTML iframe)

<iframe src="http://pckg.beskid-lang.org/api/embed/card?package=corelib_concurrency" title="corelib_concurrency on Beskid registry" width="480" height="200" style="border:0;border-radius:8px;max-width:100%;" loading="lazy" referrerpolicy="no-referrer-when-downgrade"></iframe>

Many README hosts render images reliably; iframes may be stripped or sandboxed.

Preview

pckg registry badge

Dependencies

Dependencies

Package	Version	Source	Registry
corelib_foundation	0.0.1	registry

Dependents

Dependents

This package currently has 2 dependent package(s) based on latest published manifests.

Documentation

Documentation

Open full page

schema 4

graph-v1

src/Prelude.bd

corelib_concurrency

0.0.1

Concurrency

Yield

NowMillis

ProcessorCount

SetProcessorCount

Fiber

Fiber

Join

Detach

Cancel

MapJoinError

Channel

SendOk

Channel

Handle

Create

CreateWithOptions

Send

Receive

TrySend

TryReceive

Close

MapSendStatus

MapReceiveError

ChannelOptions

ChannelCapacity

ChannelOptions

Default

Unbounded

Bounded

SingleReader

SingleWriter

EncodeCapacity

EncodeFlags

ChannelError

ChannelError

FiberJoinStatus

Ok

Cancelled

Panicked

StackOverflow

NotDone

FiberError

FiberError

Hub

Hub

Create

Register

Unregister

WaitReceive

HubReceiveResult

HubReceiveResult

HubError

HubError

Mutex

Mutex

Create

Lock

TryLock

Unlock

MutexGuard

MutexGuard

MutexError

MutexError

WaitGroup

WaitGroup

Create

Add

Done

Wait

Dependencies

corelib_foundation

Collections

Array

List

List

New

Count

IsEmpty

Push

Pop

Get

Map

MapEntry

Map

New

Count

IsEmpty

Insert

Remove

ContainsKey

Get

Queue

Queue

New

Count

IsEmpty

Enqueue

Dequeue

Peek

Set

Set

New

Count

IsEmpty

Add

Remove

Contains

Stack

Stack

New

Count

IsEmpty

Push

Pop

Peek

Core

Results

Result

IsOk

IsError

ErrorHandling

ErrorInfo

NewErrorInfo

IsErrorInfoEmpty

String

Query

Operators

QueryState

Where

Select

Take

Skip

Count

First

CollectArray

Contracts

Option

HasValue

Execution

IsDeferred

MaterializeCount

System

Threading

Testing

Contracts

AssertionPredicate

AssertionMessageBuilder

Assertions

trigger_failure

Fail

AssertTrue

AssertFalse

AssertEqualI64

AssertEqualString

AssertNotEqualI64

AssertContains

__alloc

__array_len

__array_new

__channel_close

__channel_create

__channel_receive

__channel_receive_value

__channel_send

__channel_try_receive

__channel_try_send

__fiber_cancel

__fiber_current_id

__fiber_detach

__fiber_join

__fiber_join_value

__fiber_now_millis

__fiber_processor_count

__fiber_spawn

__fiber_spawn_with_cancel_slot

__fiber_yield

__gc_register_root

__gc_root_handle

__gc_unregister_root

__gc_unroot_handle

__gc_write_barrier

__hub_create

__hub_register

__hub_unregister

__hub_wait_receive

__hub_wait_receive_index

__hub_wait_receive_value

__interop_dispatch_ptr

__interop_dispatch_unit

__interop_dispatch_usize

__mutex_create

__mutex_lock

__mutex_try_lock

__mutex_unlock

__panic_str

__str_len

__str_new

__syscall_read

__syscall_write

__test_bytes_len

__test_bytes_ptr

__wait_group_add

__wait_group_create

__wait_group_done

__wait_group_wait

range

Concurrency

Concurrency

Copy link

module

public

src/Prelude.bd:2

Members

Name	Type	Kind
Yield	unit Yield()	function
NowMillis	i64 NowMillis()	function
ProcessorCount	i64 ProcessorCount()	function
SetProcessorCount	unit SetProcessorCount(i64 count)	function
Fiber		module
Channel		module
ChannelOptions		module
ChannelError		module
FiberJoinStatus		module
FiberError		module
Hub		module
HubReceiveResult		module
HubError		module
Mutex		module
MutexGuard		module
MutexError		module
WaitGroup		module
Status		module

Summary

Concurrency package prelude: cooperative fibers, channels, and OS threading.

No description.

Source

Source

Json

.beskid/docs/api.json

Ratings

Ratings & quality

Quality score

59%

steady • maintained

0 review(s)

Review distribution

5

0

4

0

3

0

2

0

1

0

Score decomposition

Update cadence 60% · w 0.42

Downloads momentum 70% · w 0.35

Review confidence 40% · w 0.23

Community

No threads yet. Start the first discussion for this package.