Java Thread - hành vi lạ Thread.interrupted() và tương lai.cancel (true)

Question

Tôi muốn quản lý một danh sách các đối tượng tương lai được trả về bởi TaskExecutor của tôi.
Tôi đã một cái gì đó như thế này

List<Future<String>> list 

void process(ProcessThis processThis) {  
    for (...) { 
     Future<String> future = taskExecutor.submit(processThis); 
     list.add(future) 
    } 
} 


void removeFutures() { 
    for(Future future : list) { 
     assert future.cancel(true); 
} 

ProcessThis là một nhiệm vụ mà thực hiện Callable < String> và kiểm tra Thread.interrupted() tình trạng

public String call() { 
     while (true) { 
      if (Thread.interrupted()) { 
       break; 
      } 
      doSomething(); 
     } 
    } 

Bây giờ vấn đề là chỉ là một tập hợp con của các Threads đồng thời trả về 'true' khi Thread.interrupted() được gọi.
Xác nhận trong removeFutures() trả về giá trị true cho mỗi tương lai bị xóa (tôi đã chọn isDone() và isCompleted() là
Số lượng Chủ đề bị gián đoạn là ngẫu nhiên. đôi khi 2 ...
Tôi thực sự không hiểu vấn đề ở đâu. Nếu tôi gọi future.cancel (true) và điều này trả về true ... và sau đó tôi kiểm tra Thread.interrupted (điều này được gọi chỉ một lần), tôi mong đợi này để trả lại sự thật là tốt.
Bất kỳ ý tưởng về những gì tôi bị mất?

tôi đang trên build java 1.6.0_02-b05

Answer 1

ít nhất, bạn nên khôi phục lại interr uption flag để làm cho taskExecutor nhận biết được sự gián đoạn của luồng:

public String call() { 
    while (true) { 
     if (Thread.interrupted()) { 
      Thread.currentThread().interrupt(); 
      break; 
     } 
     doSomething(); 
    } 
} 

Answer 2

Một vấn đề tiềm năng mà ngắt thường bị nuốt chửng. Vì vậy, một nơi nào đó sâu trong doSomething() (hoặc thậm chí trong lớp tải), một gián đoạn có thể bị bắt bởi, nói, wait() và sau đó bị loại bỏ bởi 'bất cẩn' mã. Gián đoạn là ác, IMO.

Có thể đáng để kiểm tra xem tất cả các nhiệm vụ của bạn có thực sự chạy tại thời điểm hủy hay không.

Answer 3

Hãy lưu ý rằng Thread.interrupted() trả lại trạng thái bị gián đoạn hiện tại và sau đó xóa nó, vì vậy tất cả các lời gọi trong tương lai sẽ trả về false. Những gì bạn muốn có lẽ là Thread.currentThread().isInterrupted().

Cũng lưu ý rằng future.cancel(true) thường sẽ chỉ trả về false nếu tác vụ đã được hoàn thành hoặc hủy. Nếu nó trả về true, đó là không đảm bảo rằng nhiệm vụ thực sự sẽ bị hủy bỏ.

Điều gì đang xảy ra trong doSomething()? Có thể là một RuntimeException đang thoát ở đâu đó do ngắt. Bạn có cài đặt UncaughtExceptionHandler không? Nếu không, bạn sẽ cần phải chuyển số ThreadFactory đến số Executor sẽ đặt trình xử lý ngoại lệ và đăng nhập bất kỳ ngoại lệ nào bị thiếu.