package com.dec.fbs9100;
|
|
import java.util.Timer;
|
import java.util.concurrent.ExecutorService;
|
import java.util.concurrent.Executors;
|
|
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.Logger;
|
|
import com.base.AppConfig;
|
import com.battdata_rt.BattData_RT;
|
import com.battdata_rt.BattData_RT_Array;
|
import com.battdata_rt.BattStatData;
|
|
public class BattDataTestPro_Thread extends Thread {
|
|
private ExecutorService m_WorkThreadPool;
|
private BattData_RT_Array m_Data;
|
private int BattTestCountMax = 10;
|
private int WorkThreadCountMax = 300;
|
|
private BattTestState m_BattTestState;
|
|
Logger logger = null;
|
|
public BattDataTestPro_Thread(AppParam param, AppConfig cfg, BattData_RT_Array data)
|
{
|
logger = LogManager.getLogger(this.getClass());
|
|
BattTestCountMax = param.getBattTestGroupCountMax(AppParam.AppParam_Discharge);
|
WorkThreadCountMax = cfg.getWorkThreadCountMax();
|
m_Data = data;
|
|
m_WorkThreadPool = Executors.newFixedThreadPool(WorkThreadCountMax);
|
m_BattTestState = new BattTestState(BattTestCountMax);
|
}
|
//-----------------------------------------------------------------------------//
|
private class BattTestState{
|
|
private int[] battgroup_working_num;
|
|
public BattTestState(int size)
|
{
|
battgroup_working_num = new int[size];
|
for(int n=0; n<BattTestCountMax; n++)
|
{
|
battgroup_working_num[n] = -1;
|
}
|
}
|
|
public boolean putBattTesttingState( int index, boolean is_testting )
|
{
|
boolean res = false;
|
|
int search_index = 0;
|
for( search_index=0; search_index<battgroup_working_num.length; search_index++ )
|
{
|
if( index == battgroup_working_num[search_index] )
|
{
|
if(false == is_testting)
|
{
|
battgroup_working_num[search_index] = -1;
|
}
|
else
|
{
|
res = true;
|
}
|
break;
|
}
|
}
|
|
if(search_index >= battgroup_working_num.length)
|
{
|
if(true == is_testting)
|
{
|
for(int n=0; n<battgroup_working_num.length; n++)
|
{
|
if(battgroup_working_num[n] < 0)
|
{
|
battgroup_working_num[n] = index;
|
res = true;
|
break;
|
}
|
}
|
}
|
}
|
|
return res;
|
}
|
}
|
//-----------------------------------------------------------------------------//
|
@Override
|
public void run() {
|
logger.info("BattDataTestPro_Thread Started By TimerTask ...");
|
Timer timer = new Timer();
|
MyBattTestTask myTask1 = new MyBattTestTask();
|
timer.scheduleAtFixedRate(myTask1, 1000, 1000);
|
|
while(true)
|
{
|
try {
|
sleep(1000);
|
} catch (InterruptedException e) {
|
logger.error(e.toString(), e);
|
}
|
}
|
}
|
|
class MyBattTestTask extends java.util.TimerTask{
|
String info = "MyBattTestTask By TimerTask";
|
|
@Override
|
public void run() {
|
// TODO Auto-generated method stub
|
try
|
{
|
for(int n=0; n<m_Data.getItemCount(); n++)
|
{
|
BattData_RT rt_data = m_Data.getItem(n);
|
|
boolean need_to_store = false;
|
need_to_store = rt_data.checkIfDataNeedStore();
|
|
boolean batt_is_testing = false;
|
if((BattStatData.BATTSTATE_CHARGE == rt_data.getBattTestType())
|
|| (BattStatData.BATTSTATE_DISCHARGE == rt_data.getBattTestType())
|
|| (BattStatData.BATTSTATE_MONITOR == rt_data.getBattTestType())
|
|| (true == need_to_store))
|
{
|
batt_is_testing = true;
|
}
|
|
if(true == m_BattTestState.putBattTesttingState(n, batt_is_testing))
|
{
|
if(true == need_to_store)
|
{
|
m_WorkThreadPool.execute(rt_data.mSqlTask);
|
}
|
}
|
else
|
{
|
rt_data.clearStoreDataBusyTag();
|
}
|
}
|
} catch (Exception e) {
|
logger.error(e.toString(), e);
|
}
|
}
|
|
public String getInfo(){
|
return info;
|
}
|
public void setInfo(String info){
|
this.info = info;
|
}
|
}
|
}
|
