|
@@ -52,6 +52,7 @@ public class StatRunner {
|
|
} catch (InterruptedException e) {
|
|
} catch (InterruptedException e) {
|
|
e.printStackTrace();
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
|
|
+
|
|
//老上传
|
|
//老上传
|
|
oldUploadPools = generatePools(oldUploadPools, 2);
|
|
oldUploadPools = generatePools(oldUploadPools, 2);
|
|
oldUploadPools.execute(new OldUploadRunner());
|
|
oldUploadPools.execute(new OldUploadRunner());
|
|
@@ -62,7 +63,7 @@ public class StatRunner {
|
|
//重试上传
|
|
//重试上传
|
|
retryUploadPools = generatePools(retryUploadPools, 2);
|
|
retryUploadPools = generatePools(retryUploadPools, 2);
|
|
retryUploadPools.execute(new RetryUploadRunner());
|
|
retryUploadPools.execute(new RetryUploadRunner());
|
|
- // retryUploadPools.execute(new FileUploadsOss(UploadsQueue.failFileQueue));
|
|
|
|
|
|
+ // 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()) {
|