为了避免在关闭执行器时剩余任务不能完成，在关闭执行器之前需要等待所有任务都完成。下面是一个示例代码：

import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit;

public class ShutdownExecutorExample { public static void main(String[] args) throws InterruptedException { ExecutorService executor = Executors.newFixedThreadPool(4); for(int i=0; i<10; i++) { executor.submit(new Task(i)); } executor.shutdown(); boolean isTerminated = false; while(!isTerminated) { isTerminated = executor.awaitTermination(500, TimeUnit.MILLISECONDS); } } }

class Task implements Runnable { private int taskNumber; public Task(int taskNumber) { this.taskNumber = taskNumber; }

@Override public void run() { System.out.println("Task " + taskNumber + " is running..."); try { Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("Task " + taskNumber + " is completed."); } }

在上述代码中，我们使用了ExecutorService接口来创建了一个固定线程池，然后将10个任务提交到执行器，并在所有任务完成后关闭执行器。在关闭执行器之前，我们使用awaitTermination()方法等待执行所有任务，该方法将阻塞并检查是否已经过了给定的时间段，如果在这段时间内所有任务都完成了，那么将返回true。如果没有，它将继续等待，直到所有任务都完成或等待时间超时。