/* * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER. * * Copyright (c) 2007 Sun Microsystems Inc. All Rights Reserved * * The contents of this file are subject to the terms * of the Common Development and Distribution License * (the License). You may not use this file except in * compliance with the License. * * You can obtain a copy of the License at * https://opensso.dev.java.net/public/CDDLv1.0.html or * opensso/legal/CDDLv1.0.txt * See the License for the specific language governing * permission and limitations under the License. * * When distributing Covered Code, include this CDDL * Header Notice in each file and include the License file * at opensso/legal/CDDLv1.0.txt. * If applicable, add the following below the CDDL Header, * with the fields enclosed by brackets [] replaced by * your own identifying information: * "Portions Copyrighted [year] [name of copyright owner]" * * $Id: SystemTimerPool.java,v 1.5 2008/09/05 00:51:02 ww203982 Exp $ * * Portions Copyrighted 2012-2016 ForgeRock AS. */ package com.sun.identity.common; import com.sun.identity.shared.Constants; import com.sun.identity.shared.debug.Debug; import com.sun.identity.shared.configuration.SystemPropertiesManager; import org.forgerock.util.thread.listener.ShutdownListener; /** * SystemTimerPool is a TimerPool which shared in the system. */ public class SystemTimerPool { /** The name of the {@link TimerPool} instance. */ public static final String TIMER_NAME = "SystemTimerPool"; /** The name of the {@link TimerPool} scheduler. */ public static final String SCHEDULER_NAME = TIMER_NAME + TimerPool.SCHEDULER_SUFFIX; protected static TimerPool instance; public static final int DEFAULT_POOL_SIZE = 3; private static int poolSize; static { poolSize = DEFAULT_POOL_SIZE; String size = SystemPropertiesManager.get( Constants.SYSTEM_TIMERPOOL_SIZE); if (size != null) { try { poolSize = Integer.parseInt(size); } catch (NumberFormatException ex) { // Don't load the Debug object in static block as it can // cause issues when doing a container restart. Debug debug = Debug.getInstance(TIMER_NAME); debug.error("SystemTimerPool.: incorrect pool size " + size + " defaulting to " + DEFAULT_POOL_SIZE); } } } /** * Create and return the system timer pool. */ public static synchronized TimerPool getTimerPool() { if (instance == null) { ShutdownManager shutdownMan = ShutdownManager.getInstance(); // Don't load the Debug object in static block as it can // cause issues when doing a container restart. instance = new TimerPool(TIMER_NAME, poolSize, false, Debug.getInstance(TIMER_NAME)); try { shutdownMan.addShutdownListener(new ShutdownListener() { public void shutdown() { instance.shutdown(); instance = null; } }); } catch(IllegalMonitorStateException e) { instance.shutdown(); instance = null; throw e; } } return instance; } }