大概是这样么?
```java
import java.util.concurrent.BlockingDeque;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class TT {

public static void main(String[] args) throws Exception{
threadPoolExecutor.execute(() -> {
try {
String a = "";
while (a != null){
a = blockingDeque.poll(10, TimeUnit.SECONDS);
System.out.println(a);
}
System.out.println("consumer exit.");
} catch (InterruptedException e) {
e.printStackTrace();
}
});
Thread.sleep(2000);
executeInternal();
Thread.sleep(2000);
executeInternal();
}

private static ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
2,
2,
60,
TimeUnit.SECONDS,
new LinkedBlockingDeque<>(4));


private static BlockingDeque<String> blockingDeque = new LinkedBlockingDeque<>();

private static void executeInternal() {
threadPoolExecutor.execute(() -> {
try {
blockingDeque.put("123");
} catch (InterruptedException e) {
e.printStackTrace();
}
});
}

}
```