cn.orionsec.kit.lang.support.progress

Class ByteTransferRateProgress

java.lang.Object

cn.orionsec.kit.lang.support.progress.ByteTransferProgress

cn.orionsec.kit.lang.support.progress.ByteTransferRateProgress

All Implemented Interfaces:

Progress

public class ByteTransferRateProgress
extends ByteTransferProgress

数据传输进度条 (实时速率计算)

Since:

2021/11/6 23:07

Version:

1.0.0

Author:

Jiahang Li

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	computeRate 是否计算实时速率
protected int	interval 计算间隔 ms
protected long	nowRate 当前速度 byte

Fields inherited from class cn.orionsec.kit.lang.support.progress.ByteTransferProgress

callback, current, done, end, endTime, error, start, startTime

Constructor Summary

Constructors

Constructor and Description
ByteTransferRateProgress(long end)
ByteTransferRateProgress(long start, long end)

Method Summary

Modifier and Type	Method and Description
ByteTransferRateProgress	computeRate()
ByteTransferRateProgress	computeRate(int interval) 开启计算实时速率
long	getNowRate()
ByteTransferRateProgress	rateAcceptor(Consumer<? super ByteTransferRateProgress> rateAcceptor) 进度回调
ByteTransferRateProgress	rateExecutor(ExecutorService rateExecutor) 进度调度器
void	start() 开始

Methods inherited from class cn.orionsec.kit.lang.support.progress.ByteTransferProgress

accept, callback, endTime, finish, finish, getCurrent, getEnd, getEndTime, getProgress, getStart, getStartTime, isDone, isError, reset, setCurrent, setEnd, setStart, startTime, usedTime

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

computeRate

protected boolean computeRate

是否计算实时速率

interval

protected int interval

计算间隔 ms

nowRate

protected volatile long nowRate

当前速度 byte

Constructor Detail

ByteTransferRateProgress

public ByteTransferRateProgress(long end)

ByteTransferRateProgress

public ByteTransferRateProgress(long start,
                                long end)

Method Detail

computeRate

public ByteTransferRateProgress computeRate()

computeRate

public ByteTransferRateProgress computeRate(int interval)

开启计算实时速率

Parameters:

interval - 间隔

rateExecutor

public ByteTransferRateProgress rateExecutor(ExecutorService rateExecutor)

进度调度器

Parameters:

rateExecutor - 线程池

Returns:

this

rateAcceptor

public ByteTransferRateProgress rateAcceptor(Consumer<? super ByteTransferRateProgress> rateAcceptor)

进度回调

Parameters:

rateAcceptor - acceptor

Returns:

this

start

public void start()

Description copied from interface: Progress

开始

Specified by:

start in interface Progress

Overrides:

start in class ByteTransferProgress

getNowRate

public long getNowRate()