Duda sobre integración de pool de conexiones

[sfx4ever]

Hola, soy nuevo en el tema de las Pool de conexiones y necesito ayuda. Tras leer este artículo:
http://www.chuidiang.com/java/mysql/...Conexiones.php

lo entiendo todo perfectamente, pero no tengo claro como integrarlo con mi programa, un servidor de sockets que abre un hilo por cada conexión entrante y aparte otro hilo paralelo principal que hace como unas 30-50 consultas UPDATE cada 5 segs.

Este es el código:

Código PHP:

  public class servidorES 
{ 
           
    // punto de entrada a nuestro programa 
    public static void main(String [] array)     
    { 
      
        //cargar el driver de mysql 
        try    { 
           Class.forName("org.gjt.mm.mysql.Driver"); 
        }  
        catch (Exception e)    { 
            System.out.println("Error1: "+e); 
           e.printStackTrace(); 
        } 
 
        
        //arranca el hilo principal 
        PnjIAES pnjia = new PnjIAES(); 
        pnjia.start(); 
 
        servidorES instancia = new servidorES(array);     
        instancia.arranca(); 
    } 
         
     
    boolean arranca() 
    { 
          
        try 
        { 
             
            ServerSocket s = new ServerSocket(puerto); 
 
            depura("Esperando conexion..."); 
             
            while(true)  // bucle infinito ....  
            { 
                Socket entrante = s.accept(); 
                peticionES pCliente = new peticionES(entrante); 
                pCliente.start(); 
            } 
             
        } 
        catch(Exception e) 
        { 
            depura("Error en servidor\n" + e.toString()); 
        } 
         
        return true; 
    } 
     
} 
 
 
 
class PnjIAES extends Thread 
{ 
 
 public PnjIAES(){  
        DEBUG = 2; 
        dormir=5000; 
        //inicializar variables 
        //.... 
 } 
 
  
public void run(){ //iniciar hilo 
 
    try{ 
 
            conexion = DriverManager.getConnection (dbhost,dbuser, dbpass); 
            
            s = conexion.createStatement(); 
            
            while(true){ 
                //hacer consultas aqui, unas 30-50 UPDATE por cada 5 segundos 
 
                //dormir xx segundos 
                try{ 
                    sleep(dormir); 
                }catch(Exception e){ 
                    depura("exc:"+e.toString()); 
                    e.printStackTrace(); 
                } 
            } 
 
         }catch(Exception e){ 
            System.out.println("e2: "+e.toString()); 
            e.printStackTrace(); 
        } 
}//run 
 
} 
 
 
class peticionES extends Thread 
{ 
 
      private Socket scliente     = null;       
       peticionES(Socket ps) 
       {              
         
        scliente = ps; 
        
       } 
     
 public void run() // implementamos el metodo run 
    { 
 
    depura("Procesamos conexion"); 
 
     
        // Establecemos la conexion con la base de datos. 
        Connection conexion = null; 
        try{ 
              conexion = DriverManager.getConnection (dbhost,dbuser, dbpass); 
 
 
        }catch(Exception e){ 
            depura(e.toString()); 
        } 
 
 
        boolean conectado = true;     
 
        do{ //bucle principal de cada hilo 
 
            //varias consultas (de 1 a 5) de cualquier tipo (select,update) cada segundo 
 
        }while(conectado==true); 
         
    } 
}  
   

¿alguna idea de donde declarar el dataSource, basicDataSource, etc y como accedo a ellos desde la clase PnjIAES o desde cada peticion?

GRACIAS