RejectedExecutionHandler에서 작업 필드를 가져 오는 방법은 무엇입니까?

Question

executor에 의해 거부 된 Task을 알고 싶습니다. 예를 들어, 거부 된 작업의 이름을 얻고 싶습니다. 그러나 RejectedExecutionHandler에서이 작업을 수행 할 수 없습니다!

public static void main(String[] args) throws Exception{ 
    ThreadPoolExecutor executor = new ThreadPoolExecutor(1, 1, 1L, TimeUnit.SECONDS, new SynchronousQueue<Runnable>(), 
      (Runnable r, ThreadPoolExecutor executor1) -> { 
       //TODO 
       //want to get the task name 
       System.out.println("in reject:"); 
    }); 
    Task t1 = new Task("t1"); 
    Task t2 = new Task("t2"); 
    Future<Integer> t1Fe = executor.submit(t1); 
    Future<Integer> t2Fe = executor.submit(t2); 

    System.out.println(t1Fe.get()); 
    System.out.println(t2Fe.get()); 
} 

static class Task implements Callable{ 
    private String name; 

    public Task(String name) { 
     this.name = name; 
    } 

    @Override 
    public Object call() throws Exception { 
     try { 
      Thread.sleep(1000); 
     } catch (InterruptedException e) { 
      e.printStackTrace(); 
     } 
     System.out.println(1); 
     return name; 
    } 
} 

Answer 1

나는 submit 방법을 무시하고 FutureTask 클래스를 오버라이드 (override) :

여기 내 코드입니다!

public static void main(String[] args) throws Exception{ 
    ThreadPoolExecutor executor = new ThreadPoolExecutor(1, 1, 1L, TimeUnit.SECONDS, new SynchronousQueue<Runnable>(), 
      (Runnable r, ThreadPoolExecutor executor1) -> { 
       //TODO 
       //want to get the task name 
       MyFutureTask task = (MyFutureTask)r; 
       System.out.println("in reject:"+task.name); 
    }); 
    Task t1 = new Task("t1"); 
    Task t2 = new Task("t2"); 
    Future<Integer> t1Fe = submit(executor,t1); 
    Future<Integer> t2Fe = submit(executor,t2); 

    System.out.println(t1Fe.get()); 
    System.out.println(t2Fe.get()); 
} 

public static Future submit(ThreadPoolExecutor executor,Callable task) { 
    if (task == null) throw new NullPointerException(); 
    MyFutureTask ftask = new MyFutureTask(task); 
    ftask.setName(((Task)task).name); 
    executor.execute(ftask); 
    return ftask; 
} 

static class MyFutureTask extends FutureTask{ 
    private String name; 
    public MyFutureTask(Callable callable) { 
     super(callable); 
    } 

    public String getName() { 
     return name; 
    } 

    public void setName(String name) { 
     this.name = name; 
    } 
} 
static class Task implements Callable{ 
    private String name; 

    public Task(String name) { 
     this.name = name; 
    } 

    @Override 
    public Object call() throws Exception { 
     try { 
      Thread.sleep(1000); 
     } catch (InterruptedException e) { 
      e.printStackTrace(); 
     } 
     System.out.println(1); 
     return name; 
    } 
}