Reduce resources used on 2nd async with a semaphore

pulibrary · Oct 11, 2023 · cdd4eed · cdd4eed
1 parent 2b0e132
commit cdd4eed
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/app/services/card_image_loading_service.rb b/app/services/card_image_loading_service.rb
@@ -33,9 +33,10 @@ def import_disk(disk)
     logger.info("Fetching disk #{disk} file list")
     filenames = disk_array(disk)
     progress_bar.total += filenames.count
-    Sync do |task|
+    Sync do
+      semaphore = Async::Semaphore.new(10_000)
       filenames.map do |file_name|
-        task.async do
+        semaphore.async do
           progress_bar.increment
           find_or_create_card_image(file_name)
         end