@@ -4,6 +4,7 @@ let numRequest = 0 // 正在执行数量
|
||||
const maxRequest = 6 // 可配置
|
||||
let taskTimer // 轮询的定时器
|
||||
var cachedTask = {} // 存放的任务数据
|
||||
let sortType = 1
|
||||
var i= 0
|
||||
let startExecuteTask = null
|
||||
let endExecuteTask = performance.now()
|
||||
@@ -14,7 +15,9 @@ async function executeTask() {
|
||||
// stopTaskTimer()
|
||||
if (taskPool.length > 0) {
|
||||
let startSortTime = performance.now()
|
||||
// sortTaskPool()
|
||||
if( sortType ){
|
||||
sortTaskPool()
|
||||
}
|
||||
let endSortTime = performance.now()
|
||||
var requestNum = Math.min(taskPool.length, maxRequest)
|
||||
const tasks = taskPool.splice(0, requestNum);
|
||||
@@ -116,14 +119,16 @@ function removeTask(seriesId){
|
||||
}
|
||||
startTaskTimer()
|
||||
}
|
||||
function setSortType(type){
|
||||
sortType = type
|
||||
}
|
||||
function resetRequestPool(){
|
||||
taskPool = []
|
||||
pendingList =[]
|
||||
cachedTask = {}
|
||||
sortType = 1
|
||||
}
|
||||
function resetCachedTask(){
|
||||
taskPool = []
|
||||
pendingList =[]
|
||||
cachedTask = {}
|
||||
}
|
||||
function buildImageRequestTask(imageId,seriesId, config = {}) {
|
||||
@@ -140,6 +145,7 @@ function buildImageRequestTask(imageId,seriesId, config = {}) {
|
||||
export default {
|
||||
addTaskIntoPool,
|
||||
executeTask,
|
||||
setSortType,
|
||||
sortTaskPool,
|
||||
startTaskTimer,
|
||||
stopTaskTimer,
|
||||
|
||||
Reference in New Issue
Block a user