test/java/util/concurrent/locks/Lock/TimedAcquireLeak.java

Print this page

        

*** 62,72 **** static String outputOf(InputStream is) throws IOException { return outputOf(new InputStreamReader(is, "UTF-8")); } ! final static ExecutorService drainers = Executors.newFixedThreadPool(12); static Future<String> futureOutputOf(final InputStream is) { return drainers.submit( new Callable<String>() { public String call() throws IOException { return outputOf(is); }});} --- 62,72 ---- static String outputOf(InputStream is) throws IOException { return outputOf(new InputStreamReader(is, "UTF-8")); } ! static final ExecutorService drainers = Executors.newFixedThreadPool(12); static Future<String> futureOutputOf(final InputStream is) { return drainers.submit( new Callable<String>() { public String call() throws IOException { return outputOf(is); }});}