001/*
002 * This file is part of McIDAS-V
003 *
004 * Copyright 2007-2025
005 * Space Science and Engineering Center (SSEC)
006 * University of Wisconsin - Madison
007 * 1225 W. Dayton Street, Madison, WI 53706, USA
008 * https://www.ssec.wisc.edu/mcidas/
009 * 
010 * All Rights Reserved
011 * 
012 * McIDAS-V is built on Unidata's IDV and SSEC's VisAD libraries, and
013 * some McIDAS-V source code is based on IDV and VisAD source code.  
014 * 
015 * McIDAS-V is free software; you can redistribute it and/or modify
016 * it under the terms of the GNU Lesser Public License as published by
017 * the Free Software Foundation; either version 3 of the License, or
018 * (at your option) any later version.
019 * 
020 * McIDAS-V is distributed in the hope that it will be useful,
021 * but WITHOUT ANY WARRANTY; without even the implied warranty of
022 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
023 * GNU Lesser Public License for more details.
024 * 
025 * You should have received a copy of the GNU Lesser Public License
026 * along with this program.  If not, see https://www.gnu.org/licenses/.
027 */
028package edu.wisc.ssec.mcidasv.monitors;
029
030import java.util.Map;
031import java.util.concurrent.ConcurrentHashMap;
032import java.util.concurrent.Executors;
033import java.util.concurrent.ScheduledExecutorService;
034import java.util.concurrent.ScheduledFuture;
035import java.util.concurrent.TimeUnit;
036
037import edu.wisc.ssec.mcidasv.monitors.memory.MemoryMonitor;
038import edu.wisc.ssec.mcidasv.monitors.time.TimeMonitor;
039
040import ucar.unidata.util.CacheManager;
041
042public class MonitorManager {
043
044    public enum MonitorType { MEMORY, TIME };
045
046    private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(3);
047
048    private final Map<MonitorType, Monitorable> monitors = new ConcurrentHashMap<>();
049
050    private final Map<Monitorable, ScheduledFuture<?>> woot = new ConcurrentHashMap<>();
051
052    public MonitorManager() {
053        monitors.put(MonitorType.MEMORY, new MemoryMonitor(this, 75, 95));
054        monitors.put(MonitorType.TIME, new TimeMonitor());
055    }
056
057    public void addListener(final MonitorType type, final Monitoring listener) {
058        Monitorable m = monitors.get(type);
059        if (!m.hasMonitors()) {
060            woot.put(m, scheduler.scheduleWithFixedDelay(m, 0, 2, TimeUnit.SECONDS));
061        }
062        m.addMonitor(listener);
063    }
064
065    public void removeListener(final MonitorType type, final Monitoring listener) {
066        Monitorable m = monitors.get(type);
067        m.removeMonitor(listener);
068        if (!m.hasMonitors()) {
069            ScheduledFuture<?> handle = woot.remove(m);
070            if (handle != null) {
071                handle.cancel(false);
072            }
073        }
074    }
075
076    public void scheduleClearCache() {
077        Runnable r = new Runnable() {
078            public void run() {
079                CacheManager.clearCache();
080            }
081        };
082        scheduler.schedule(r, 1, TimeUnit.SECONDS);
083    }
084}