Examples of java.util.concurrent.ExecutorService.submit()

Class java.util.concurrent.ExecutorService

Examples of java.util.concurrent.ExecutorService.submit()

java.util.concurrent.ExecutorService.submit()
Submits a value-returning task for execution and returns a Future representing the pending results of the task. The Future's {@code get} method will return the task's result uponsuccessful completion.
If you would like to immediately block waiting for a task, you can use constructions of the form {@code result = exec.submit(aCallable).get();}
Note: The {@link Executors} class includes a set of methodsthat can convert some other common closure-like objects, for example, {@link java.security.PrivilegedAction} to{@link Callable} form so they can be submitted. @param task the task to submit @param < T> the type of the task's result @return a Future representing pending completion of the task @throws RejectedExecutionException if the task cannot bescheduled for execution @throws NullPointerException if the task is null

            final AtomicBoolean condition = new AtomicBoolean(true);
            final CyclicBarrier trigger = new CyclicBarrier(2);
            final CountDownLatch latch = new CountDownLatch(10);


            ExecutorService notificationsPool = Executors.newFixedThreadPool(4);
            notificationsPool.submit(new Callable<Void>() {
                public Void call() throws Exception {
                    trigger.await();
                    while (condition.get()) {
                        fNotifier.fireTestStarted(null);
                        latch.countDown();

View Full Code Here

        CountDownLatch latch = new CountDownLatch(numThreads);
        ExecutorService executor = Executors.newFixedThreadPool(numThreads);
        Thread[] threads = new Thread[numThreads];
        for (int i = 0; i < numThreads; i++) {
            SingletonBeanLookupThread singletonBeanLookupThread = new SingletonBeanLookupThread(latch, jndiName, numTimes);
            executor.submit(singletonBeanLookupThread);
        }
        latch.await();


        Context ctx = new InitialContext();
        SimpleSingletonLocal bean = (SimpleSingletonLocal) ctx.lookup(jndiName);

View Full Code Here

        CountDownLatch latch = new CountDownLatch(numThreads);
        ExecutorService executor = Executors.newFixedThreadPool(numThreads);
        Thread[] threads = new Thread[numThreads];
        for (int i = 0; i < numThreads; i++) {
            SingletonBeanAccessThread singletonBeanAccessThread = new SingletonBeanAccessThread(latch, jndiName, numTimes);
            executor.submit(singletonBeanAccessThread);
        }
        latch.await();


        Context ctx = new InitialContext();
        SimpleSingletonLocal counter = (SimpleSingletonLocal) ctx.lookup(jndiName);

View Full Code Here

        fNotifier.addListener(listener2);


        final int numParallelTests = 4;
        ExecutorService pool = Executors.newFixedThreadPool(numParallelTests);
        for (int i = 0; i < numParallelTests; ++i) {
            pool.submit(new Runnable() {
                public void run() {
                    fNotifier.fireTestStarted(null);
                }
            });
        }

View Full Code Here

                .base(basePath)
                .host("localhost")
                .port(7070);


        ExecutorService bg = Executors.newSingleThreadExecutor();
        bg.submit(new Callable<Object>() {
            @Override
            public Object call() {
                try {
                    HazelCatcher.run(opts);
                    return null;

View Full Code Here

        InputStream inStream = getClass().getClassLoader().getResourceAsStream(resourceURI);
        final String in = context.getTypeConverter().convertTo(String.class, inStream);


        ExecutorService executor = Executors.newFixedThreadPool(poolSize);
        for (int i = 0; i < files; i++) {
            executor.submit(new Callable<Object>() {
                public Object call() throws Exception {
                    template.sendBody(endpointURI, in);
                    return null;
                }
            });

View Full Code Here


      ExecutorService executor = Executors.newFixedThreadPool(NUMBER_OF_THREADS);


      for (int thread = 0; thread < NUMBER_OF_THREADS; thread++)
      {
         executor.submit(new Runnable() {
            @Override
            public void run()
            {
               for (int i = 0; i < REQUESTS_PER_THREAD; i++)
               {

View Full Code Here

                            for (final Dependency<?> dep : deps) {
                                if (!isConcurrent(constructor, dep.getParameterIndex())) {
                                    suppliers.add(getCreator(dep.getKey()));
                                }
                                else {
                                    final Future<?> future = executor.submit(new Callable<Object>() {
                                        @Override
                                        public Object call() throws Exception {
                                            return getCreator(dep.getKey()).get();
                                        }
                                    });

View Full Code Here

                    subset.getReplicated());
              collectException(slice.flush(subset), exceptions);
                remaining.remove(subset);
              rollbackVersion(subset.getReplicated(), oldVersions, remaining);
            } else {
              futures.add(threadPool.submit(new Flusher(slice, subset)));
            }
        }
        for (Future<Collection> future : futures) {
            try {
              collectException(future.get(), exceptions);

View Full Code Here

                    futures = new ArrayList<Future<Number>>();
        DeleteExecutor call = new DeleteExecutor();
        call.executor = ex;
        call.query = qs.next();
        call.params = params;
        futures.add(threadPool.submit(call));
      }
      for (Future<Number> future : futures) {
        try {
          Number n = future.get();
          if (n != null)

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.