public void hundredStreamsConcurrently() throws Exception {
ExecutorService e = Executors.newFixedThreadPool(5);
for (int i = 0; i < 10; i++) {
e.execute(new Runnable() {
public void run() {
for (int i = 0; i < 10; i++) {
try {
isJarInputStreamReadable();
}
catch (Exception e) {
m_failure = e;
}
}
}
});
}
e.shutdown();
e.awaitTermination(10, TimeUnit.SECONDS);
assert m_failure == null : "Test failed: " + m_failure.getLocalizedMessage();
}
|