Examples of java.util.concurrent.ThreadPoolExecutor.shutdown()

Class java.util.concurrent.ThreadPoolExecutor

Examples of java.util.concurrent.ThreadPoolExecutor.shutdown()

java.util.concurrent.ThreadPoolExecutor.shutdown()
Initiates an orderly shutdown in which previously submitted tasks are executed, but no new tasks will be accepted. Invocation has no additional effect if already shut down.
This method does not wait for previously submitted tasks to complete execution. Use {@link #awaitTermination awaitTermination}to do that. @throws SecurityException {@inheritDoc}

                Thread.sleep(1000);
            } catch (InterruptedException ignore) {
            }
        }


        workerPool.shutdown();
        ResultProcessor.printResults(workers, host, url.toString(), contentLength);
    }


    private HttpParams getHttpParams(int socketTimeout, boolean useHttp1_0) {
        HttpParams params = new BasicHttpParams();

View Full Code Here

                Thread.sleep(1000);
            } catch (InterruptedException ignore) {
            }
        }


        workerPool.shutdown();
        ResultProcessor.printResults(workers, host, url.toString(), contentLength);
    }


    private HttpParams getHttpParams(int socketTimeout, boolean useHttp1_0) {
        HttpParams params = new BasicHttpParams();

View Full Code Here


    @Override
    public void shutdown(final boolean arg0) {
        if (threadPoolExecutorUsed) {
            final ThreadPoolExecutor tpe = (ThreadPoolExecutor) executor;
            tpe.shutdown();
            if (arg0) {
                final int timeout = SystemInstance.get().getOptions().get(OPENEJB_EJB_TIMER_POOL_AWAIT_SECONDS, 5);
                try {
                    tpe.awaitTermination(timeout, TimeUnit.SECONDS);
                } catch (final InterruptedException e) {

View Full Code Here

              } catch (ExecutionException e) {
                throw new IOException(e);
              }
            } while (!executorDone);
    }
          executor.shutdown();
        }
        HiveInterruptUtils.checkInterrupted();
        for (Map.Entry<String, ContentSummary> entry : resultMap.entrySet()) {
          ContentSummary cs = entry.getValue();

View Full Code Here


        shutdownHub.addRegistryShutdownListener(new RegistryShutdownListener()
        {
            public void registryDidShutdown()
            {
                executorService.shutdown();
            }
        });


        return new ParallelExecutorImpl(executorService, thunkCreator, perthreadManager);
    }

View Full Code Here


        shutdownHub.addRegistryShutdownListener(new RegistryShutdownListener()
        {
            public void registryDidShutdown()
            {
                executorService.shutdown();
            }
        });


        return new ParallelExecutorImpl(executorService, thunkCreator, perthreadManager);
    }

View Full Code Here

                Thread.sleep(1000);
            } catch (final InterruptedException ignore) {
            }
        }


        workerPool.shutdown();
        return ResultProcessor.collectResults(workers, host, config.getUrl().toString());
    }


}

View Full Code Here

                Thread.sleep(1000);
            } catch (final InterruptedException ignore) {
            }
        }


        workerPool.shutdown();
        return ResultProcessor.collectResults(workers, host, config.getUrl().toString());
    }


}

View Full Code Here

        for (int i=0; i<1000; i++) {
            executor.execute(createSessionTask);
            executor.execute(startStopTask);
        }


        executor.shutdown();
        assertTrue("executor terminated", executor.awaitTermination(30, TimeUnit.SECONDS));
        assertTrue("no exceptions: " + exceptions, exceptions.isEmpty());
    }
}

View Full Code Here

                Thread.sleep(1000);
            } catch (InterruptedException ignore) {
            }
        }


        workerPool.shutdown();
        ResultProcessor.printResults(workers, host, url.toString(), contentLength);
    }


    private HttpParams getHttpParams(int socketTimeout, boolean useHttp1_0) {
        HttpParams params = new BasicHttpParams();

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.