class 컨트롤러 extends CI_Controller {
	
	public function __construct()
	{
		parent::__construct();
		$this->load->model('모델명');
	}
	
	public function index(){
		
	}
	
	public function queue_add ($job_name="") {
		if($job_name == ""){
			echo "잡이 정의되지 않음."; 
			exit;
		}
		$this->모델명->queue_add($job_name);
	}
	
	
	public function start_queue () {
		while (1) {
			$result = $this->모델명->get_queue();
			$cur_count = $result->num_rows();
			if ($cur_count > 0) {
				// 작업이 있으면 일을 시작해라.
				$this->모델명->process_queue($result);
			} else {
				// 없으면 잠시 기달림.
				sleep(rand(3, 7));
			}
		}
	}
}

line = "\n";
        if(php_sapi_name() != 'cli') $this->line = "
";
    }
        
    //큐데이터 객체 리턴
    function get_queue() {
    	
    	$this->db->select("*");
    	$this->db->from("테이블명");
    	$this->db->order_by("aq_no","asc");
    	$query = $this->db->get();
    	
    	return $query;
    }
    
    //큐 실행.
    function process_queue($obj) {
    	$row = $obj->row_array();
    	
    	//큐삭제..
    	$this->db->delete('테이블명', array('aq_no' => $row['aq_no']));
    	
    	if(method_exists( $this,$row['aq_job_name'] )){
    		//예외가 발생할 수 있으니 큐 삭제 후 실행.
    		$this->$row['aq_job_name']();
    	}
    }
    
    //큐추가
    function queue_add($job_name) {
    	
    	$this->db->select("*");
    	$this->db->from("테이블명");
    	$this->db->where("aq_job_name",$job_name);
    	$this->db->order_by("aq_no","asc");
    	$query = $this->db->get();
    	//중복 등록을 막으려고 넣었어요  필요없으시면 빼도됨.
    	if( $query->num_rows() > 0 ){
	    	return false; 
    	} else {
    		$sql = array(
    				'aq_job_name'	=>	$job_name
    		);
    		$result = $this->db->insert('테이블명', $sql);
    		
    		return true;
    	}
    }
    
    function __destruct () {
    	
    }
}