# QueueRunner

**Repository Path**: liyongyao/QueueRunner

## Basic Information

- **Project Name**: QueueRunner
- **Description**: 在线程中的queue，创建一个runner，将需要异步处理的任务添加进去，在运行完所有任务之后，如果规定时间内没有新任务加入，自动关闭线程。如果设定了callback逻辑，会调用callback方法来完成后续处理
- **Primary Language**: Java
- **License**: GPL-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2016-03-21
- **Last Updated**: 2020-12-18

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

#简单示例
```
//创建一个runner
RunnerDemo runnerDemo = new RunnerDemo();
//创建一个任务
TaskModel tm = new TaskModel();
tm.setTaskName("task 1");
/将任务添加到runner中
runnerDemo.add(tm, 3);
//将任务提交到线程中，也可以提交到线程池中
new Thread(runnerDemo).start();
```
#快速入门
一、配置queue-config.xml
```
<?xml version="1.0" encoding="UTF-8"?>
<root>
	<params>
		<param name="thread.enable.exit" value="true" /><!-- 是否开启线程自动退出 -->
		<param name="queue.fetch.interval" value="1000"/><!-- 队列取值间隔 ，需要大于100毫秒，默认值1000毫秒-->
		<param name="queue.max.warttime" value="30000" /><!-- 线程最大等待时间，超过该毫秒数，线程退出 (需要thread.enable.exit值为true)-->
		<param name="queue.max.size" value="100" /><!-- 线程最大数量，超过该数量时，添加返回false -->
	</params>
</root>
```
二、查看测试示例

RunnerTest.java 是测试用例

RunnerDemo.java 是测试逻辑实现，该类 extends QueueRunner<TaskModel, String>，两个泛型分别是输入模型和返回值类型

TaskModel.java  是任务输入模型

三、处理回调

在逻辑实现中，实现RunnerCallBack.java 接口，并添加到逻辑实现类中（测试示例中对应RunnerDemo.java）