TeamPiped-mirror/Piped-Backend
1
0
Fork 0
mirror of https://github.com/TeamPiped/Piped-Backend.git synced 2024-08-14 23:51:41 +00:00
Code Issues Projects Releases Packages Wiki Activity

Merge pull request #334 from TeamPiped/async-cache

Browse source 
Use AsyncLoadingCache for Downloader requests.
This commit is contained in:
Kavin 2022-08-12 19:53:19 +05:30 • committed by GitHub
commit d9da850287
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 4 deletions
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;
import com.github.benmanes.caffeine.cache.AsyncLoadingCache;
import com.github.benmanes.caffeine.cache.Caffeine;
import com.github.benmanes.caffeine.cache.LoadingCache;
import com.github.benmanes.caffeine.cache.Scheduler;
import com.grack.nanojson.JsonParserException;
import me.kavin.piped.consts.Constants;
@ -27,14 +27,19 @@ public class DownloaderImpl extends Downloader {
private static long cookie_received;
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)
.scheduler(Scheduler.systemScheduler())
.maximumSize(100).build(this::executeRequest);
.maximumSize(100).buildAsync(this::executeRequest);
@Override
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);
}
}
/**