package com.fastbee.base.core.annotation;

import java.lang.annotation.*;

/**
 * 多线程异步处理设备数据，新建线程组处理
 *
 * @author bill
 */
@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface AsyncBatch {

    /*批量处理的最大消息数*/
    int maxMessageSize() default 5000;

    /*线程数*/
    int poolSize() default 2;

    /*最大等待时间*/
    int maxWaitTime() default 1000;

    /*最小处理消息数*/
    int minMessageSize() default 100;

}