DefaultExecutorServiceProvider.java
01 /*
02  * SPDX-License-Identifier: Apache-2.0
03  *
04  * Copyright 2008-2017 the original author or authors.
05  *
06  * Licensed under the Apache License, Version 2.0 (the "License");
07  * you may not use this file except in compliance with the License.
08  * You may obtain a copy of the License at
09  *
10  *     http://www.apache.org/licenses/LICENSE-2.0
11  *
12  * Unless required by applicable law or agreed to in writing, software
13  * distributed under the License is distributed on an "AS IS" BASIS,
14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15  * See the License for the specific language governing permissions and
16  * limitations under the License.
17  */
18 package org.codehaus.griffon.runtime.core.threading;
19 
20 import javax.inject.Provider;
21 import java.util.concurrent.ExecutorService;
22 import java.util.concurrent.Executors;
23 import java.util.concurrent.ThreadFactory;
24 import java.util.concurrent.atomic.AtomicInteger;
25 
26 /**
27  @author Andres Almiray
28  @since 2.2.0
29  */
30 public class DefaultExecutorServiceProvider implements Provider<ExecutorService> {
31     @Override
32     public ExecutorService get() {
33         return Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()new DefaultThreadFactory());
34     }
35 
36     private static class DefaultThreadFactory implements ThreadFactory {
37         private static final AtomicInteger poolNumber = new AtomicInteger(1);
38         private final ThreadGroup group;
39         private final AtomicInteger threadNumber = new AtomicInteger(1);
40         private final String namePrefix;
41 
42         private DefaultThreadFactory() {
43             SecurityManager s = System.getSecurityManager();
44             group = (s != null? s.getThreadGroup() :
45                 Thread.currentThread().getThreadGroup();
46             namePrefix = "griffon-pool-" +
47                 poolNumber.getAndIncrement() +
48                 "-thread-";
49         }
50 
51         public Thread newThread(Runnable r) {
52             Thread t = new Thread(group, r, namePrefix + threadNumber.getAndIncrement()0);
53             if (t.isDaemon()) t.setDaemon(false);
54             if (t.getPriority() != Thread.NORM_PRIORITYt.setPriority(Thread.NORM_PRIORITY);
55             return t;
56         }
57     }
58 }