package net.jrtechs; public class SleepWork extends WorkGenerator { @Override Work generateWork(E param) { return new Work() { @Override E runTask() { try { Thread.sleep(500); } catch (InterruptedException e) { e.printStackTrace(); } return param; } }; } }