스레드 실행이 루프에서 완료되지 않았습니다.

Question

스레드 당 10 개의 스레드를 사용하여 50000 개의 레코드를 데이터베이스에 삽입해야합니다. Ex. 스레드 1은 1-5000을 삽입하고 스레드 2는 5001-10000을 삽입합니다.

이 작업을 수행하려면 ExecutorService를 사용해야합니다.

코드

ExecutorService threadPool = Executors.newFixedThreadPool(10); 
int i=0; 
while(i<vVec.size()) 
{ 
    if(i<vVec.size()) 
    { 
    DBInsertDetail rrr = (DBInsertDetail)vVec.get(i); 
    TestThread t1 = new TestThread(rrr); 
    threadPool.execute(t1); 

    } 

    i++; 
} 


try { 
     threadPool.shutdown(); 
     boolean bTermination = false; 


     while (true) 
     { 
    bTermination = threadPool.awaitTermination(15, TimeUnit.MINUTES); 

    if(!bTermination) 
    { 
     Log.debug("Awaiting completion of threads."); 
    } 
    else 
    { 
     Log.debug("Threads Completed."+iTermiVal); 
     break; 
    } 

    if(threadPool.isTerminated()) 
    { 
     break; 
    }  

    } 
} catch (Exception e) {} 

TestThread 클래스

public class TestThread implements Runnable 
{ 
    private volatile DBInsertDetail syncc; 

    public Thread1(DBInsertDetail syncc) { 
     this.syncc = syncc;   
    } 

    public void run() { 

    try 
    {   this.syncc.cardCreProcess(syncc.getIncre(),syncc.getStarterial(),syncc.getCurTblSeq()); 
      Thread.sleep(1000); 
     } catch (Exception e) {    
      e.printStackTrace(); 
     } 
    } 
} 

DBInsertDetail 클래스

public class DBInsertDetail { 
public void cardCreProcess(int iNum,int iCurrSerl,int iCurTblSeq) 
{ 
    int iCardCountTest = 0; 
    try 
    { 
    synchronized(this) 
    { 

    for (int i = 0; i < iNum; i++) 
    { 
    iCurrSerl++; 
    iCurTblSeq++; 
    iCardCountTest++;  

    CmnDet stkDet = new CmnDet(); 
    Data crdData = new Data(); 
    String sNo = crdData.getNextNo(pro, prof, sBranch, iCurrSerl); 

    stkDet.setNo(sNo); 
    stkDet.setCod(""+iCurTblSeq); 

    if (!stkDet.saveToDataBase(con)) 
    { 
    sErrorMsg +="Error Occured" + "\n"; 
    } 

    } 

    } 
}catch(Exception ex) 
{ 
ex.printStackTrace(); 

} 
finally{ 
    //commit and return connection 
} 

} 
} 

문제는이 큰 번호에 대해 올바르게 실행되지 않습니다이다. 스레드 10000 당 레코드를 늘리면 프로세스가 오류없이 실행되지만 일괄 처리의 일부만 삽입합니다. 어떤 생각?

Answer 1

이것은 잘못되었습니다. :) 스레드의 일관성으로 인해 그것을 떠날

스레드에서 1000ms 잠. 1 초입니다.

10000 삽입 = 10000 초 = 166 분.

스레드 풀이 15 분 동안 실행되도록 허용 한 다음 종료합니다.