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_PRIORITY) t.setPriority(Thread.NORM_PRIORITY);
55 return t;
56 }
57 }
58 }
|