Package java.util.concurrent

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

447
448
449
450
451
452
453
454
455
456
457
                TimeUnit.MILLISECONDS );


        Thread.sleep( 10200 );

        executor.shutdownNow();
        ksession.halt();
        t.join();

        if (t.getError() != null) {
            fail(t.getError().getMessage());
View Full Code Here
147
148
149
150
151
152
153
154
155
156
157
            context.error(e);
         }
      }
      try {
         sessionPingTask.cancel(true);
         executor.shutdownNow();
         config.save();
         console.stop();
      } catch (Exception e) {
      }
   }
View Full Code Here
128
129
130
131
132
133
134
135
136
137
138
            ViewProcessor vp = new RemoteViewProcessor(componentInfo.getUri(), jmsConnector, scheduler);
            toolContext.setViewProcessor(vp);
            toolContext.setContextManager(new Closeable() {
              @Override
              public void close() throws IOException {
                scheduler.shutdownNow();
                jmsConnector.close();
              }
            });
          } else {
            String clazzName = componentInfo.getAttribute(ComponentInfoAttributes.REMOTE_CLIENT_JAVA);
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
127
128
129
130
131
132
133
134
135
136
137
      Thread.currentThread().sleep(500);
    } catch(InterruptedException ie) {
      ;//do nothing
    }
   
    service.shutdownNow();
   
    //check that the right words have been retrieved
    Assert.assertEquals( "lie", runner1.word.getBaseForm());
    Assert.assertEquals("bark", runner2.word.getBaseForm());
  }
View Full Code Here
173
174
175
176
177
178
179
180
181
182
183
        {
            executor.schedule( new Runnable()
            {
                public void run()
                {
                    executor.shutdownNow();
                }
            }, stopAfter, TimeUnit.SECONDS );
        }
        if ( !report )
        {
View Full Code Here
181
182
183
184
185
186
187
188
189
190
191
        }
        if ( !report )
        {
            System.in.read();
            System.out.println();
            executor.shutdownNow();
        }

        session.output.println( "" );
    }
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.