Application: gvSIG desktop » gvSIG raster

/* gvSIG. Geographic Information System of the Valencian Government

 *

 * Copyright (C) 2007-2008 Infrastructures and Transports Department

 * of the Valencian Government (CIT)

 *

 * This program is free software; you can redistribute it and/or

 * modify it under the terms of the GNU General Public License

 * as published by the Free Software Foundation; either version 2

 * of the License, or (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,

 * MA  02110-1301, USA.

 *

 */

package org.gvsig.raster.cache.tile;

import java.io.File;

import org.gvsig.raster.cache.tile.exception.TileGettingException;

import org.gvsig.raster.cache.tile.pool.ThreadPool;

import org.gvsig.raster.cache.tile.provider.Downloader;

import org.gvsig.tools.junit.AbstractLibraryAutoInitTestCase;

/**

 * 

 * @author Nacho Brodin (nachobrodin@gmail.com)

 */

public class TestThreadPool extends AbstractLibraryAutoInitTestCase {

        private static final int  WIDTH           = 3;

        private static final int  HEIGHT          = 3;

        private static final int  DOWNLOAD_TIME   = 500;

        public class MyDownloader implements Downloader {

                public Tile downloadTile(Tile tile) {

                        //tile.getFile() -> Aqui se guarda el fichero descargado

                        try {

                                Thread.sleep(DOWNLOAD_TIME);

                        } catch (InterruptedException e) {

                                e.printStackTrace();

                        }

                        return tile;

                }

                public Tile readTileFromDisk(Tile tile) throws TileGettingException {

                        // TODO Auto-generated method stub

                        return null;

                }

                /*

                 * (non-Javadoc)

                 * @see org.gvsig.raster.cache.tile.provider.Downloader#cancelDownloading(boolean)

                 */

                public void cancelDownloading(boolean cancel) {

                }

                public Object[] getCrashImage(int w, int h) {

                        // TODO Auto-generated method stub

                        return null;

                }

                public Object[] getDownloadingImage(int w, int h) {

                        // TODO Auto-generated method stub

                        return null;

                }

        }

        public void start() {

                try {

                        this.doSetUp();

                } catch (Exception e) {

                        e.printStackTrace();

                }

                this.testStack();

        }

        @Override

        protected void doSetUp() throws Exception {

                System.err.println("TestThreadPool running...");

        }

        public void testStack() {

                ThreadPool pool = TileCacheLocator.getManager().createThreadPool(false);

                MyDownloader d = new MyDownloader();

                for (int x = 0; x < HEIGHT; x++) {

                        for (int y = 0; y < WIDTH; y++) {

                                Tile t = TileCacheLocator.getManager().createTile(0, x, y);

                                t.setSharedPipe(pool.getTilePipe());

                                t.setDownloader(d);

                                t.setFile(new File(""));

                                pool.addTask(t);

                        }

                }

                int nCollected = 0;

                while (nCollected < (WIDTH * HEIGHT)) {

                        Tile tile = (Tile)pool.getTilePipe().getAtomicTask();

                        System.out.println("Getting " + tile.getRow() + " " + tile.getCol() + " P:" + tile.getPriority());

                        nCollected ++;

                }

                if(pool != null)

                        pool.destroyPool();

        }

}