Cassandra Thrift Client и многопоточность

Question

У меня есть данные (сетевые пакеты) для вставки в базу данных Cassandra!

К сожалению, моему приложению требуется около 1 минуты, чтобы вставить 10000 пакетов!

Я ищу, если есть кто-нибудь, кто может помочь мне использовать концепцию многопоточности Java для ускорения вставки! Вот мой код:

PcapPacketHandler<String> jpacketHandler;
    jpacketHandler = new PcapPacketHandler<String>() {
GestionPacketDAO g1;
int row=0;
public void nextPacket(PcapPacket packet, String user) {
 row++;

  String s = packet.toHexdump();

   try {
               g1 = new GestionPacketDAO();                 
    g1.Insert(s, row);// Insert is the function which insert data into  database
           } 
 catch (InvalidRequestException exg) 
   {Logger.getLogger(AccueilInsertion.class.getName()).log(Level.SEVERE, null, exg); 
            } 
   catch (TException exg) {

      Logger.getLogger(AccueilInsertion.class.getName()).log(Level.SEVERE, null,    exg);
        }
        }}

Спасибо!!