OnJava8-Examples/concurrent/Breakable.java at master · CSapprenticeWT/OnJava8-Examples · GitHub

Repository navigation

// concurrent/Breakable.java

// 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;

}