concurrency

Problem

Lacking the following implementation:

impl<T> Threaded for T
where
    T: Agent<Reach = Private>,

Implementation Tips

• Implementing Threaded is a g

current return queueOfferResult == QueueOfferResult.enqueued();

It would be great to see, how to properly implement refreshing + pagination + search.

I'd like to configure stack size(and probably give threads names), afaik it's currently not possible.

In the following file we have already ported some tests from Go to Rust:
https://github.com/crossbeam-rs/crossbeam-channel/blob/master/tests/golang.rs

The idea is to blindly port all the tests for Go channels line by line, which will give us additional confidence in the correctness of crossbeam-channel.

In the test file, you can find stubs with links to the original tests written in Go and

Document the newly introduced data types from zio.concurrent:

• ConcurrentMap
• ConcurrentSet
• CountdownLatch
• CyclicBarrier

Replace concrete Bastion Executor with Agnostik.
So everyone can use whatever they want as guarantee.