Skip to content

Instantly share code, notes, and snippets.

View lusong1986's full-sized avatar

lusong lusong1986

  • shanghai
View GitHub Profile
package net.warmwaffles.utils.concurrent;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock;
/**
* A light wrapper around the {@link ThreadPoolExecutor}. It allows for you to pause execution and