kavin/Piped-Backend
1
0
Fork 0
mirror of https://github.com/TeamPiped/Piped-Backend.git synced 2024-12-14 14:20:29 +05:30
Code Issues Projects Releases Wiki Activity

Use AsyncLoadingCache for Downloader requests.

Browse Source
This commit is contained in:
Kavin 2022-08-12 19:50:53 +05:30
parent e9189f2d00
commit 48c780ed90
No known key found for this signature in database
GPG Key ID: 49451E4482CC5BCD
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/me/kavin/piped/utils/DownloaderImpl.java
View File

@ -1,7 +1,7 @@
package me.kavin.piped.utils; package me.kavin.piped.utils;
import com.github.benmanes.caffeine.cache.AsyncLoadingCache;
import com.github.benmanes.caffeine.cache.Caffeine; import com.github.benmanes.caffeine.cache.Caffeine;
import com.github.benmanes.caffeine.cache.LoadingCache;
import com.github.benmanes.caffeine.cache.Scheduler; import com.github.benmanes.caffeine.cache.Scheduler;
import com.grack.nanojson.JsonParserException; import com.grack.nanojson.JsonParserException;
import me.kavin.piped.consts.Constants; import me.kavin.piped.consts.Constants;
@ -27,14 +27,19 @@ public class DownloaderImpl extends Downloader {
private static long cookie_received; private static long cookie_received;
private static final Object cookie_lock = new Object(); private static final Object cookie_lock = new Object();
final LoadingCache<Request, Response> responseCache = Caffeine.newBuilder() final AsyncLoadingCache<Request, Response> responseCache = Caffeine.newBuilder()
.expireAfterWrite(1, TimeUnit.MINUTES) .expireAfterWrite(1, TimeUnit.MINUTES)
.scheduler(Scheduler.systemScheduler()) .scheduler(Scheduler.systemScheduler())
.maximumSize(100).build(this::executeRequest); .maximumSize(100).buildAsync(this::executeRequest);
@Override @Override
public Response execute(@NotNull Request request) { public Response execute(@NotNull Request request) {
return responseCache.get(request); try {
System.out.println(responseCache.get(request).get());
return responseCache.get(request).get();
} catch (Exception e) {
throw new RuntimeException(e);
}
} }
/** /**