private void processDelete()

in src/main/java/com/netflix/bdp/s3mper/metastore/impl/MetastoreJanitor.java [160:185]

• 21 lines of code
• 4 McCabe index (conditional complexity)

    private void processDelete() throws Exception {
        registerShutdownHook();
        
        for (int i = 0; i < deleteThreads; i++) {
            DeleteWriterTask delete = new DeleteWriterTask(db, deleteLimiter, queue);
            
            tasks.add(delete);
            futures.add(executor.submit(delete));
        }
        
        synchronized(scanFutures) {
            for (Future future : scanFutures) {
                future.get();
            }
        }
        
        synchronized(tasks) {
            for (AbstractDynamoDBTask task : tasks) {
                task.running = false;
            }
        }
       
        log.info("Shutting down . . .");
        executor.shutdown();
        log.info("Shutdown complete.");
    }