View Javadoc

1   package org.apache.maven.surefire.junitcore.pc;
2   
3   /*
4    * Licensed to the Apache Software Foundation (ASF) under one
5    * or more contributor license agreements.  See the NOTICE file
6    * distributed with this work for additional information
7    * regarding copyright ownership.  The ASF licenses this file
8    * to you under the Apache License, Version 2.0 (the
9    * "License"); you may not use this file except in compliance
10   * with the License.  You may obtain a copy of the License at
11   *
12   *     http://www.apache.org/licenses/LICENSE-2.0
13   *
14   * Unless required by applicable law or agreed to in writing,
15   * software distributed under the License is distributed on an
16   * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
17   * KIND, either express or implied.  See the License for the
18   * specific language governing permissions and limitations
19   * under the License.
20   */
21  
22  import java.util.concurrent.ExecutorService;
23  import java.util.concurrent.TimeUnit;
24  
25  /**
26   * Parallel strategy for non-shared thread pool in private package.
27   *
28   * @author Tibor Digana (tibor17)
29   * @see AbstractThreadPoolStrategy
30   * @since 2.16
31   */
32  final class NonSharedThreadPoolStrategy
33      extends AbstractThreadPoolStrategy
34  {
35      NonSharedThreadPoolStrategy( ExecutorService threadPool )
36      {
37          super( threadPool );
38      }
39  
40      @Override
41      public boolean hasSharedThreadPool()
42      {
43          return false;
44      }
45  
46      @Override
47      public boolean finished()
48          throws InterruptedException
49      {
50          boolean wasRunning = canSchedule();
51          getThreadPool().shutdown();
52          try
53          {
54              getThreadPool().awaitTermination( Long.MAX_VALUE, TimeUnit.NANOSECONDS );
55              return wasRunning;
56          }
57          finally
58          {
59              disable();
60          }
61      }
62  }