Add dummy cancellation support

This commit is contained in:
tarsin committed 2023-01-30 13:23:30 +08:00
1 parent c878952237
commit 54c8183666
1 file changed
+2
@@ -65,6 +65,7 @@ import java.util.ArrayList;
import java.util.LinkedList; import java.util.LinkedList;
import java.util.List; import java.util.List;
import java.util.Queue; import java.util.Queue;
import java.util.concurrent.CancellationException;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.LinkedBlockingDeque; import java.util.concurrent.LinkedBlockingDeque;
@@ -1220,6 +1221,7 @@ public final class SpiderQueen implements Runnable {
var body = response.body(); var body = response.body();
var received = mSpiderDen.saveFromBufferedSource(index, body , (contentLength, receivedSize, bytesRead) -> { var received = mSpiderDen.saveFromBufferedSource(index, body , (contentLength, receivedSize, bytesRead) -> {
if (mStoped) throw new CancellationException();
mPagePercentMap.put(index, (float) receivedSize / contentLength); mPagePercentMap.put(index, (float) receivedSize / contentLength);
notifyPageDownload(index, contentLength, receivedSize, bytesRead); notifyPageDownload(index, contentLength, receivedSize, bytesRead);
return null; return null;