ThreadPool Class

Used to spawn threads and execute tasks. Instances of this class should override the process() method which is called by individual threads. Objects (e.g. data) are added to a queue via the add() method. Individual threads wait for data to be added to the queue. As new data is added, it is assigned to a thread to process. The thread, in turn, calls the process() method. The ThreadPool will run indefinitely, unless the done() method is called. The join() method can be used to join the ThreadPool to the caller's thread. Example:

      //Instantiate thread pool
        int numThreads = 2;
        ThreadPool pool = new ThreadPool(numThreads){
            public void process(Object obj){
                //Do something!
            }
        };

      //Start the thread
        pool.start();


      //Add tiles to the pool
        for (int i : new int[]{1,2,3,4,5,6,7,8,9,10}){
            pool.add(i);
        }


      //Notify the pool that we have finished added records
        pool.done();


      //Wait for threads to finish
        pool.join();
     

        Connection conn = (Connection) get("conn", () -> {
            return database.getConnection();
        });