Package java.util.concurrent

Examples of java.util.concurrent.ScheduledExecutorService.shutdownNow()

271
272
273
274
275
276
277
278
279
280
281
        assertEquals("", 1D, inst.getSamplers().get("a").get("1").getValue(), 0.01D);
        assertEquals("", 2D, inst.getSamplers().get("a").get("2").getValue(), 0.02D);
        assertEquals("", 5D, inst.getSamplers().get("b").get("1").getValue(), 0.5D);

        scheduledExecutorService.shutdownNow();
    }

    public void testAll() throws Exception {
        Instrumentation inst = new Instrumentation();
        inst.addVariable("a", "1", new Instrumentation.Variable<Long>() {
View Full Code Here
80
81
82
83
84
85
86
87
88
89
90
      }
      catch (SQLException e) {
         Assert.fail("Should not have timed out: " + e.getMessage());
      }
      finally {
         scheduler.shutdownNow();
         ds.close();
      }
   }

   @Test
View Full Code Here
127
128
129
130
131
132
133
134
135
136
137
      }
      catch (SQLException e) {
         Assert.fail("Should not have timed out.");
      }
      finally {
         scheduler.shutdownNow();
         ds.close();
      }
   }

   @Test
View Full Code Here
205
206
207
208
209
210
211
212
213
214
215
      }
      catch (SQLException e) {
         Assert.fail("Should not have timed out.");
      }
      finally {
         scheduler.shutdownNow();
         ds.close();
      }
   }

   @Test
View Full Code Here
1143
1144
1145
1146
1147
1148
1149
1150
1151
1152
1153
        executor.shutdown();
        try {
            // Wait for all remaining background threads to terminate
            if (!executor.awaitTermination(10, TimeUnit.SECONDS)) {
                log.warn("Attempting to forcibly shutdown runaway threads");
                executor.shutdownNow();
            }
        } catch (InterruptedException e) {
            log.warn("Interrupted while waiting for background threads", e);
        }
View Full Code Here
1125
1126
1127
1128
1129
1130
1131
1132
1133
1134
1135
        executor.shutdown();
        try {
            // Wait for all remaining background threads to terminate
            if (!executor.awaitTermination(10, TimeUnit.SECONDS)) {
                log.warn("Attempting to forcibly shutdown runaway threads");
                executor.shutdownNow();
            }
        } catch (InterruptedException e) {
            log.warn("Interrupted while waiting for background threads", e);
        }
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
    private void stop() {
        ScheduledExecutorService executor = this.executor;
        if (executor == null) {
            return;
        }
        executor.shutdownNow();
        this.executor = null;
    }

    private class NotifyingTask implements Runnable {
        public void run() {
View Full Code Here
274
275
276
277
278
279
280
281
282
283
284
        assertEquals("", 1D, inst.getSamplers().get("a").get("1").getValue(), 0.01D);
        assertEquals("", 2D, inst.getSamplers().get("a").get("2").getValue(), 0.02D);
        assertEquals("", 5D, inst.getSamplers().get("b").get("1").getValue(), 0.5D);

        scheduledExecutorService.shutdownNow();
    }

    public void testAll() throws Exception {
        Instrumentation inst = new Instrumentation();
        inst.addVariable("a", "1", new Instrumentation.Variable<Long>() {
View Full Code Here
829
830
831
832
833
834
835
836
837
838
839
      if (scheduler != null) {
        if (log.isDebugEnabled())
          log.debug("Shutting down scheduler");
        try {
          ScheduledExecutorService exe = scheduler.getScheduledExecutor();
          List<Runnable> runables = exe.shutdownNow();
          if (log.isDebugEnabled())
            log.debug("Scheduler - shutdown: {} queued: {}", exe.isShutdown(), runables.size());
          if (scheduler != null) {
            scheduler.shutdown();
            scheduler = null;
View Full Code Here
852
853
854
855
856
857
858
859
860
861
862
      if (executor != null) {
        if (log.isDebugEnabled())
          log.debug("Shutting down executor");
        try {
          ThreadPoolExecutor exe = executor.getThreadPoolExecutor();
          List<Runnable> runables = exe.shutdownNow();
          if (log.isDebugEnabled())
            log.debug("Executor - shutdown: {} queued: {}", exe.isShutdown(), runables.size());
          if (executor != null) {
            executor.shutdown();
            executor = null;
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.