Struct qiniu_upload_manager::FixedConcurrencyProvider

pub struct FixedConcurrencyProvider(_);

固定并发数提供者

Implementations

impl FixedConcurrencyProvider

pub fn new(concurrency: usize) -> Option<Self>

创建固定并发数提供者

如果传入 0 将返回 None。

pub const fn new_with_non_zero_concurrency(concurrency: NonZeroUsize) -> Self

创建固定并发数提供者

提供 NonZeroUsize 作为并发数类型。

Examples found in repository

src/concurrency_provider/fixed.rs (line 36)

    fn default() -> Self {
        Self::new_with_non_zero_concurrency(default_non_zero_concurrency())
    }

src/scheduler/concurrent_multi_parts_uploader_scheduler.rs (lines 115-117)

    pub fn new(multi_parts_uploader: M) -> Self {
        Self {
            data_partition_provider: Box::new(FixedDataPartitionProvider::new_with_non_zero_part_size(
                default_non_zero_part_size(),
            )),
            concurrency_provider: Box::new(FixedConcurrencyProvider::new_with_non_zero_concurrency(
                default_non_zero_concurrency(),
            )),
            multi_parts_uploader,
        }
    }

pub const fn fixed_concurrency(&self) -> NonZeroUsize

获取固定并发数

Examples found in repository

src/concurrency_provider/fixed.rs (line 43)

    fn concurrency(&self) -> Concurrency {
        self.fixed_concurrency().into()
    }

Trait Implementations

impl Clone for FixedConcurrencyProvider

fn clone(&self) -> FixedConcurrencyProvider

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ConcurrencyProvider for FixedConcurrencyProvider

fn concurrency(&self) -> Concurrency

获取并发数

fn feedback(&self, _feedback: ConcurrencyProviderFeedback<'_>)

反馈并发数结果

impl Debug for FixedConcurrencyProvider

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for FixedConcurrencyProvider

fn default() -> Self

Returns the “default value” for a type.

impl From<NonZeroUsize> for FixedConcurrencyProvider

fn from(concurrency: NonZeroUsize) -> Self

Converts to this type from the input type.

impl Copy for FixedConcurrencyProvider