159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta/* 259b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * Copyright (c) 2009-2010 jMonkeyEngine 359b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * All rights reserved. 459b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * 559b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * Redistribution and use in source and binary forms, with or without 659b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * modification, are permitted provided that the following conditions are 759b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * met: 859b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * 959b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * * Redistributions of source code must retain the above copyright 1059b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * notice, this list of conditions and the following disclaimer. 1159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * 1259b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * * Redistributions in binary form must reproduce the above copyright 1359b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * notice, this list of conditions and the following disclaimer in the 1459b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * documentation and/or other materials provided with the distribution. 1559b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * 1659b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * * Neither the name of 'jMonkeyEngine' nor the names of its contributors 1759b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * may be used to endorse or promote products derived from this software 1859b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * without specific prior written permission. 1959b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * 2059b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS 2159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED 2259b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR 2359b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR 2459b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, 2559b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 2659b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR 2759b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF 2859b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING 2959b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS 3059b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 3159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta */ 3259b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 3359b2e6871c65f58fdad78cd7229c292f6a177578Scott Bartapackage com.jme3.asset; 3459b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 3559b2e6871c65f58fdad78cd7229c292f6a177578Scott Bartaimport java.util.concurrent.Callable; 3659b2e6871c65f58fdad78cd7229c292f6a177578Scott Bartaimport java.util.concurrent.ExecutorService; 3759b2e6871c65f58fdad78cd7229c292f6a177578Scott Bartaimport java.util.concurrent.Executors; 3859b2e6871c65f58fdad78cd7229c292f6a177578Scott Bartaimport java.util.concurrent.ThreadFactory; 3959b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 4059b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta/** 4159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * <code>ThreadingManager</code> manages the threads used to load content 4259b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * within the Content Manager system. A pool of threads and a task queue 4359b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * is used to load resource data and perform I/O while the application's 4459b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * render thread is active. 4559b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta */ 4659b2e6871c65f58fdad78cd7229c292f6a177578Scott Bartapublic class ThreadingManager { 4759b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 4859b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta protected final ExecutorService executor = 4959b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta Executors.newFixedThreadPool(2, 5059b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta new LoadingThreadFactory()); 5159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 5259b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta protected final AssetManager owner; 5359b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 5459b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta protected int nextThreadId = 0; 5559b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 5659b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta public ThreadingManager(AssetManager owner){ 5759b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta this.owner = owner; 5859b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta } 5959b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 6059b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta protected class LoadingThreadFactory implements ThreadFactory { 6159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta public Thread newThread(Runnable r) { 6259b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta Thread t = new Thread(r, "pool" + (nextThreadId++)); 6359b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta t.setDaemon(true); 6459b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta t.setPriority(Thread.MIN_PRIORITY); 6559b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta return t; 6659b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta } 6759b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta } 6859b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 6959b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta protected class LoadingTask implements Callable<Object> { 7059b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta private final String resourceName; 7159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta public LoadingTask(String resourceName){ 7259b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta this.resourceName = resourceName; 7359b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta } 7459b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta public Object call() throws Exception { 7559b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta return owner.loadAsset(new AssetKey(resourceName)); 7659b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta } 7759b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta } 7859b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 7959b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta// protected class MultiLoadingTask implements Callable<Void> { 8059b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta// private final String[] resourceNames; 8159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta// public MultiLoadingTask(String[] resourceNames){ 8259b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta// this.resourceNames = resourceNames; 8359b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta// } 8459b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta// public Void call(){ 8559b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta// owner.loadContents(resourceNames); 8659b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta// return null; 8759b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta// } 8859b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta// } 8959b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 9059b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta// public Future<Void> loadContents(String ... names){ 9159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta// return executor.submit(new MultiLoadingTask(names)); 9259b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta// } 9359b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 9459b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta// public Future<Object> loadContent(String name) { 9559b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta// return executor.submit(new LoadingTask(name)); 9659b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta// } 9759b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 9859b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta public static boolean isLoadingThread() { 9959b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta return Thread.currentThread().getName().startsWith("pool"); 10059b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta } 10159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 10259b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 10359b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta} 104