From 37c4cc68ed3897c273e919e3dffea83c94e7d4d2 Mon Sep 17 00:00:00 2001 From: Viktor Lofgren Date: Mon, 31 Jul 2023 10:34:42 +0200 Subject: [PATCH] TODO --- .../src/main/java/nu/marginalia/converting/DumbThreadPool.java | 1 + .../src/main/java/nu/marginalia/crawl/DumbThreadPool.java | 1 + 2 files changed, 2 insertions(+) diff --git a/code/processes/converting-process/src/main/java/nu/marginalia/converting/DumbThreadPool.java b/code/processes/converting-process/src/main/java/nu/marginalia/converting/DumbThreadPool.java index 2ea1f071..95cbf14a 100644 --- a/code/processes/converting-process/src/main/java/nu/marginalia/converting/DumbThreadPool.java +++ b/code/processes/converting-process/src/main/java/nu/marginalia/converting/DumbThreadPool.java @@ -15,6 +15,7 @@ import java.util.concurrent.atomic.AtomicInteger; * becomes available to run the task. This is useful for coarse grained * tasks where the calling thread might otherwise block for hours. */ +// TODO: This class exists in crawler as well, should probably be broken out into a common library; use the one from crawler instead public class DumbThreadPool { private final List workers = new ArrayList<>(); private final LinkedBlockingQueue tasks; diff --git a/code/processes/crawling-process/src/main/java/nu/marginalia/crawl/DumbThreadPool.java b/code/processes/crawling-process/src/main/java/nu/marginalia/crawl/DumbThreadPool.java index f82c460e..076eb9e5 100644 --- a/code/processes/crawling-process/src/main/java/nu/marginalia/crawl/DumbThreadPool.java +++ b/code/processes/crawling-process/src/main/java/nu/marginalia/crawl/DumbThreadPool.java @@ -15,6 +15,7 @@ import java.util.concurrent.atomic.AtomicInteger; * becomes available to run the task. This is useful for coarse grained * tasks where the calling thread might otherwise block for hours. */ +// TODO: This class exists in converter as well, should probably be broken out into a common library; use this version public class DumbThreadPool { private final List workers = new ArrayList<>(); private final LinkedBlockingQueue tasks;