|
@@ -54,16 +54,17 @@ public class StatRunner {
|
|
}
|
|
}
|
|
//老上传
|
|
//老上传
|
|
oldUploadPools = generatePools(oldUploadPools, 2);
|
|
oldUploadPools = generatePools(oldUploadPools, 2);
|
|
- oldUploadPools.execute(new OldUploadRunner());
|
|
|
|
- //oldUploadPools.execute(new FileUploadsOss(UploadsQueue.fileQueue));
|
|
|
|
|
|
+ // oldUploadPools.execute(new OldUploadRunner());
|
|
|
|
+ oldUploadPools.execute(new FileUploadsOss(UploadsQueue.fileQueue));
|
|
//新上传
|
|
//新上传
|
|
currentUploadPools = generatePools(currentUploadPools, 2);
|
|
currentUploadPools = generatePools(currentUploadPools, 2);
|
|
currentUploadPools.execute(new CurrentUploadRunner());
|
|
currentUploadPools.execute(new CurrentUploadRunner());
|
|
//重试上传
|
|
//重试上传
|
|
retryUploadPools = generatePools(retryUploadPools, 2);
|
|
retryUploadPools = generatePools(retryUploadPools, 2);
|
|
- retryUploadPools.execute(new RetryUploadRunner());
|
|
|
|
- // retryUploadPools.execute(new FileUploadsOss(UploadsQueue.failFileQueue));
|
|
|
|
|
|
+ // retryUploadPools.execute(new RetryUploadRunner());
|
|
|
|
+ retryUploadPools.execute(new FileUploadsOss(UploadsQueue.failFileQueue));
|
|
}
|
|
}
|
|
|
|
+
|
|
public static ExecutorService generatePools(ExecutorService oldPool, int length) {
|
|
public static ExecutorService generatePools(ExecutorService oldPool, int length) {
|
|
if (oldPool != null && !oldPool.isTerminated()) {
|
|
if (oldPool != null && !oldPool.isTerminated()) {
|
|
oldPool.shutdown();
|
|
oldPool.shutdown();
|