Package l2p.common

Examples of l2p.common.ParallelExecutor.execute()


    ParallelExecutor executor = new ParallelExecutor("cleanUpDB", Thread.NORM_PRIORITY, ClearQuery.values().length);
    try
    {
      for(ClearQuery q : ClearQuery.values())
      {
        executor.execute(q);
      }
      executor.waitForFinishAndDestroy();
      _log.info("Total cleaned: " + ClearQuery.totalDeleted + ", updated: " + ClearQuery.totalUpdated + " elements in database.");
    }
    catch(InterruptedException e)
View Full Code Here


    try
    {
      for(int i = 0; i < Tasks.objTables.length; i++)
      {
        objCounts[i] = new int[2];
        multiextractor.execute(new Tasks.CountObjectIds(Tasks.objTables[i], objCounts[i]));
      }
      multiextractor.waitForFinishAndDestroy();
    }
    catch(InterruptedException e)
    {
View Full Code Here

    multiextractor = new ParallelExecutor("extractUsedObjectIDTable::ExtractObjectIds", Thread.NORM_PRIORITY, Tasks.objTables.length);
    try
    {
      for(int i = 0; i < Tasks.objTables.length; i++)
      {
        multiextractor.execute(new Tasks.ExtractObjectIds(Tasks.objTables[i], objCounts[i], result));
      }
      multiextractor.waitForFinishAndDestroy();
    }
    catch(InterruptedException e)
    {
View Full Code Here

          String[] xy = fn.split("_");
          if(multiloader != null)
          {
            try
            {
              multiloader.execute(GeoEngine.class, "LoadGeodataFile", Byte.parseByte(xy[0]), Byte.parseByte(xy[1]));
            }
            catch(Exception e)
            {
              e.printStackTrace();
            }
View Full Code Here

    {
      for(int mapY = 0; mapY < L2World.WORLD_SIZE_Y; mapY++)
      {
        if(geodata[mapX][mapY] != null)
        {
          executor.execute(new GeoOptimizer.CheckSumLoader(mapX, mapY, geodata[mapX][mapY]));
        }
      }
    }
    try
    {
View Full Code Here

    {
      for(int mapY = 0; mapY < L2World.WORLD_SIZE_Y; mapY++)
      {
        if(geodata[mapX][mapY] != null && GeoOptimizer.checkSums != null && GeoOptimizer.checkSums[mapX][mapY] != null)
        {
          executor.execute(new GeoOptimizer.GeoBlocksMatchFinder(mapX, mapY, maxScanRegions));
        }
      }
    }
    try
    {
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.