treshenkov/credit_tracker
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

./

Browse source
This commit is contained in:
etreschenkov 2025-10-14 15:21:40 +03:00
parent 76489609c7
commit bb7606125a
2 changed files with 9 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
src/main/java/ru/nbch/credit_tracker/facade/SignalFacadeV2.java
View file

@ -98,6 +98,7 @@ public class SignalFacadeV2 {
Long packageId = signalService.registerPackage(userId, packageName); Long packageId = signalService.registerPackage(userId, packageName);
log.info("Package registered. PackageId {}. Status: {}", packageId, Status.PROCESSING.name()); log.info("Package registered. PackageId {}. Status: {}", packageId, Status.PROCESSING.name());
//create and start pipilene
savingRequest.add(new PackageToSavePayload(packageId, filePath)); savingRequest.add(new PackageToSavePayload(packageId, filePath));
} catch (Exception e) { } catch (Exception e) {
CTUtil.removeFile(filePath); CTUtil.removeFile(filePath);

9
src/main/java/ru/nbch/credit_tracker/service/task/TaskConsumerV2.java
View file

@ -51,7 +51,14 @@ public class TaskConsumerV2<X extends TaskPayloadV2, Z extends TaskPayloadV2>
putQuiet(out, POISON); putQuiet(out, POISON);
return; return;
} }
Future<Z> f = ioPool.submit(() -> dispatcher.handle(b));
Future<Z> f = ioPool.submit(() -> {
Z p = dispatcher.handle(b);
//
putQuiet(out, p);
return p;
}
);
inflight.add(f); inflight.add(f);
// чтобы не накапливать слишком много future в памяти, периодически сливаем // чтобы не накапливать слишком много future в памяти, периодически сливаем