don’t thread

Author: tburch

src/main/java/com/lowtuna/jsonblob/core/BlobCleanupJob.java

@@ -46,7 +46,9 @@ public void run() {
 
         if (localDate.isBefore(LocalDate.now().minusDays(blobAccessTtl.toDays()))) {
           log.debug("Submitting DataDirectoryCleanupJob for {}", dataDirPath);
-          executorService.submit(new DataDirectoryCleanupJob(dataDirPath, executorService, fileSystemJsonBlobManager, blobAccessTtl, om, deleteEnabled));
+          DataDirectoryCleanupJob cleanupJob = new DataDirectoryCleanupJob(dataDirPath, executorService, fileSystemJsonBlobManager, blobAccessTtl, om, deleteEnabled);
+          cleanupJob.run();
+//          executorService.submit(cleanupJob);
         }
       }
     } catch (Exception e) {

src/main/java/com/lowtuna/jsonblob/core/DataDirectoryCleanupJob.java

@@ -78,7 +78,11 @@ public DateTime apply(@Nullable String input) {
 
         log.debug("Submitting BulkBlobDeleteJobs for {} blobs in {}", toRemove.size(), dir);
         List<List<String>> subSets = Lists.partition(Lists.newArrayList(toRemove.keySet()), 1000);
-        subSets.parallelStream().forEach(list -> executorService.submit(new BulkBlobDeleteJob(Sets.newHashSet(list), fileSystemJsonBlobManager, deleteEnabled)));
+        subSets.parallelStream().forEach(list -> {
+          BulkBlobDeleteJob deleteJob = new BulkBlobDeleteJob(Sets.newHashSet(list), fileSystemJsonBlobManager, deleteEnabled);
+          deleteJob.run();
+//          executorService.submit(deleteJob);
+        });
       } catch (IOException e) {
         log.warn("Couldn't load metadata file from {}", dir.getAbsolutePath(), e);
       }