List of all items
Structs
- Adaptive
- AdaptiveWithThreshold
- ArchivedMessage
- ArchivedUniversalReceiver
- ArchivedUniversalSender
- AsyncContext
- AsyncExecutor
- AsyncHandle
- AtomicCounter
- Barrier
- BaseTask
- BlockingResultWait
- BlockingTask
- Chained
- Closure
- Condvar
- ContextualTask
- ExecutorConfig
- File
- FileOpenOptions
- Group
- HybridConfig
- HybridContext
- HybridExecutor
- InMemoryTransport
- IpcTransport
- Mapped
- Moirai
- MoiraiBuilder
- MoiraiCompat
- MoiraiIterator
- Mutex
- ParMut
- ParRef
- Parallel
- ParallelContext
- Parameterized
- PerformanceHistory
- RangeParIter
- RemoteAddress
- RwLock
- SchedulerId
- SchedulerScope
- Scope
- Sequential
- Spawner
- TaskBuilder
- TaskContext
- TaskFuture
- TaskHandle
- TaskId
- TaskResultSender
- TcpListener
- TcpStream
- Timeout
- TokioCompat
- TransportManager
- VecParIter
- VecRefParIter
- WorkBytes
- channel::ChannelConfig
- channel::ChannelStatistics
- channel::HybridChannel
- channel::HybridReceiver
- channel::HybridSender
- channel::MpmcChannel
- channel::MpmcReceiver
- channel::MpmcSender
- channel::Select
- channel::SpscConsumer
- channel::SpscProducer
- channel::SpscReceiver
- channel::SpscRing
- channel::SpscSender
- channel::UnifiedChannel
- channel::UnifiedReceiver
- channel::UnifiedSender
- channel::config::ChannelConfig
- channel::hybrid::HybridChannel
- channel::hybrid::HybridReceiver
- channel::hybrid::HybridSender
- channel::hybrid::RecvFuture
- channel::mpmc::MpmcChannel
- channel::mpmc::MpmcReceiver
- channel::mpmc::MpmcSender
- channel::select::Select
- channel::spsc::SpscConsumer
- channel::spsc::SpscProducer
- channel::spsc::SpscReceiver
- channel::spsc::SpscRing
- channel::spsc::SpscSender
- channel::stats::ChannelStatistics
- channel::unified::UnifiedChannel
- channel::unified::UnifiedReceiver
- channel::unified::UnifiedSender
- channel::unified::core::UnifiedChannel
- channel::unified::receiver::UnifiedReceiver
- channel::unified::sender::UnifiedSender
- ops::Scope
- prelude::Adaptive
- prelude::AdaptiveWithThreshold
- prelude::MoiraiIterator
- prelude::Parallel
- prelude::Sequential
- prelude::TaskBuilder
- prelude::TaskHandle
- prelude::TaskId
- prelude::Timeout
- timeout::Timeout
- timeout::TimeoutError
Enums
- Address
- ChunkBuffersError
- ExecutionContext
- ExecutionStrategy
- ExecutorError
- IdleHookRegistrationError
- PlacementFailure
- Priority
- SchedulerError
- TaskError
- TaskErrorKind
- TransportError
- WorkerPlacement
- channel::ChannelError
- channel::error::ChannelError
- ops::ChunkBuffersError
- prelude::ExecutionContext
- prelude::ExecutionStrategy
- prelude::Priority
Traits
- ArchiveSerialize
- ArchiveView
- AsyncBufRead
- AsyncIterator
- AsyncParallelIterator
- AsyncRead
- AsyncReadExt
- AsyncWrite
- AsyncWriteExt
- ExecutionBase
- ExecutionPolicy
- Executor
- ExecutorControl
- IndexedParallelIterator
- IntoAsyncIterator
- IntoParallelIterator
- IntoParallelRefIterator
- ParallelExtend
- ParallelIterator
- ParallelSlice
- ParallelSliceMut
- ResultWaitPolicy
- Task
- TaskExt
- TaskSpawner
- channel::Channel
- channel::Consumer
- channel::Producer
- channel::error::Channel
- channel::roles::Consumer
- channel::roles::Producer
- prelude::ExecutionPolicy
- prelude::ParallelSlice
- prelude::ParallelSliceMut
- prelude::Task
- prelude::TaskExt
Functions
- async_range
- block_on
- channel::mpmc
- channel::select::mpmc
- channel::select::spsc
- channel::select::unbounded
- channel::spsc
- channel::unbounded
- channel::unified::unified_channel
- channel::unified::unified_channel_with_config
- channel::unified_channel
- channel::unified_channel_with_config
- enumerate_mut_with
- enumerate_with
- fold_reduce_with
- for_each_chunk_buffers_mut_enumerated_with
- for_each_chunk_mut_enumerated_with
- for_each_chunk_mut_with
- for_each_chunk_mut_with_state
- for_each_chunk_pair_mut_enumerated_with
- for_each_chunk_quad_mut_enumerated_with
- for_each_chunk_triple_mut_enumerated_with
- for_each_index_with
- for_each_mut_with
- for_each_unit_task_many_mut_with
- for_each_unit_task_mut_with
- for_each_unit_task_pair_mut_with
- for_each_unit_task_range_with
- for_each_unit_task_triple_mut_with
- for_each_with
- global
- initialize
- join
- join_with
- map_collect_index_with
- map_collect_mut_with
- map_collect_with
- map_reduce_with
- melinoe_ext::par_partition_for_each
- melinoe_ext::par_partition_for_each_with_policy
- melinoe_ext::par_partition_map
- melinoe_ext::par_partition_map_with_policy
- moirai_iter
- moirai_iter_async
- moirai_iter_hybrid
- moirai_iter_parallel
- ops::enumerate_mut_with
- ops::enumerate_with
- ops::fold_reduce_with
- ops::for_each_chunk_buffers_mut_enumerated_with
- ops::for_each_chunk_mut_enumerated_with
- ops::for_each_chunk_mut_with
- ops::for_each_chunk_mut_with_state
- ops::for_each_chunk_pair_mut_enumerated_with
- ops::for_each_chunk_quad_mut_enumerated_with
- ops::for_each_chunk_triple_mut_enumerated_with
- ops::for_each_index_with
- ops::for_each_mut_with
- ops::for_each_unit_task_many_mut_with
- ops::for_each_unit_task_mut_with
- ops::for_each_unit_task_pair_mut_with
- ops::for_each_unit_task_range_with
- ops::for_each_unit_task_triple_mut_with
- ops::for_each_with
- ops::join
- ops::join_with
- ops::map_collect_index_with
- ops::map_collect_mut_with
- ops::map_collect_with
- ops::map_reduce_with
- ops::reduce_index_with
- ops::scope
- ops::units_per_task
- par_partition_for_each
- par_partition_for_each_with_policy
- par_partition_map
- par_partition_map_with_policy
- par_range
- reduce_index_with
- register_idle_hook
- run_idle_hooks
- scope
- sleep
- spawn_async
- spawn_fn
- timeout
- units_per_task
Type Aliases
- ExecutorResult
- IdleHook
- MoiraiScope
- SchedulerResult
- TaskResult
- TransportResult
- channel::Result
- channel::error::Result