init

leutu

2024-06-03 3ef35e6cd16bbfa206b26bb3271eac40ad020bcb

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
package com.fastbee.mq.redischannel.queue;
 
import com.fastbee.common.core.mq.DeviceReportBo;
import lombok.SneakyThrows;
 
import java.util.concurrent.LinkedBlockingQueue;
 
/**
 * @author gsb
 * @date 2022/10/10 10:13
 */
public class DeviceOtherQueue {
 
    private static final LinkedBlockingQueue<DeviceReportBo> queue = new LinkedBlockingQueue<>();
 
    /*元素加入队列,最后*/
    public static void offer(DeviceReportBo dto){
        queue.offer(dto);
    }
    /*取出队列元素 先进先出*/
    @SneakyThrows
    public static DeviceReportBo take(){
        return queue.take();
    }
}