package com.imut.szd.common;

import java.util.ArrayList;
import java.util.Iterator;

/**
 * 控制台任务类
 * 本类包含一个线程，为主线程与任务线程的通讯类。
 * 任务线程必须调用本类的writeResult方法才能将数据输出到本类中。
 * 任务线程必须设置本类的OVER属性以确定执行结束
 * 本类不宜多次执行！
 * @author shizhida
 *
 */
public class ConsoleTask {

    private ArrayList<String> resultSet;//返回结果集
    private ArrayList<String> resultBuffer;//缓冲返回结果集，当LOCK的时候将数据输出到这里
    private Runnable task;//执行的线程体
    private String consoleTaskId;//任务ID，用于在session中查找到相应对象
    public boolean LOCK;//读取锁，当主线程读取数据时先设置本参数为true，防止冲突。
    public boolean OVER;//结束判断
    public boolean NEW;//是否有新数据的判断，当写入时将本参数设置为true，避免无用的读取。
    public ConsoleTask(String id){
        LOCK = false;
        OVER = false;
        NEW = false;
        consoleTaskId = id;
        resultSet = new ArrayList<String>();
        resultBuffer = new ArrayList<String>();
        
    }
    public void start(){
        new Thread(task).start();
    }
    public Runnable getTask() {
        return task;
    }

    public void setTask(Runnable task) {
        this.task = task;
    }

    public String getConsoleTaskId() {
        return consoleTaskId;
    }

    public void setConsoleTaskId(String consoleTaskId) {
        this.consoleTaskId = consoleTaskId;
    }

    /**
     * 读取结果集的操作。
     * @return
     */
    public String[] readResult(){
        LOCK = true;//设置读取锁
        String[] result = new String[resultSet.size()];//创建返回值
        for(int i=0;i<result.length;i++){
            result[i] = resultSet.get(i);
        }
        resultSet.clear();//清空结果集
        NEW = false;//声明没有新结果
        LOCK = false;//解锁
        return result;
    }
    /**
　　*写入结果集的操作
　　**/
    public void writeResult(String res){
        if(!LOCK)//判断是否有锁，无锁执行以下代码：
        {
            //将缓冲结果集的数据转移到结果集中
            if(resultBuffer.size()!=0)
                {
                    Iterator<String> iter = resultBuffer.iterator();
                    while(iter.hasNext()){
                    resultSet.add(iter.next());
                    }
                    resultBuffer.clear();
                }
            //向结果集输出数据
            resultSet.add(res);
        }
        //若已上锁，向缓冲结果集输出数据
        else resultBuffer.add(res);
        NEW = true;//声明新结果存在
    }
    
    public void destory(){
        System.out.println("ConsoleTask "+consoleTaskId+"has been destory!");
        //SessionOperation.remove(this.getConsoleTaskId());
        this.OVER = true;
    }
}