// concurrent/Breakable.java
// (c)2017 MindView LLC: see Copyright.txt
// We make no guarantees that this code is fit for any purpose.
// Visit http://OnJava8.com for more book information.
import java.util.concurrent.*;

public class Breakable {
 String id;
 private int failcount;
 public Breakable(String id, int failcount) {
 this.id = id;
 this.failcount = failcount;
 }
 @Override
 public String toString() {
 return "Breakable_" + id +
 " [" + failcount + "]";
 }
 public static Breakable work(Breakable b) {
 if(--b.failcount == 0) {
 System.out.println(
 "Throwing Exception for " + b.id + "");
 throw new RuntimeException(
 "Breakable_" + b.id + " failed");
 }
 System.out.println(b);
 return b;
 }
}