lbqms.git - Gitblit

			@@ -2,8 +2,7 @@

			import cn.hutool.core.util.RandomUtil;
			import com.ruoyi.common.core.domain.R;
			import com.ruoyi.common.utils.redis.QueueUtils;
			import io.swagger.v3.oas.annotations.tags.Tag;
			import com.ruoyi.common.redis.utils.QueueUtils;
			import lombok.RequiredArgsConstructor;
			import lombok.extern.slf4j.Slf4j;
			import org.springframework.web.bind.annotation.GetMapping;
			@@ -22,7 +21,6 @@
			* @version 3.6.0
			*/
			@Slf4j
			@Tag(name = "优先队列演示案例", description = "优先队列")
			@RequiredArgsConstructor
			@RestController
			@RequestMapping("/demo/queue/priority")
			@@ -36,16 +34,9 @@
			@GetMapping("/add")
			public R<Void> add(String queueName) {
			// 用完了一定要销毁否则会一直存在
			boolean b = QueueUtils.destroyPriorityQueueObject(queueName);
			boolean b = QueueUtils.destroyQueue(queueName);
			log.info("通道: {} , 删除: {}", queueName, b);
			// 初始化设置一次即可此处注意不允许用内部类或匿名类
			boolean flag = QueueUtils.trySetPriorityQueueComparator(queueName, new PriorityDemoComparator());
			if (flag) {
			log.info("通道: {} , 设置比较器成功", queueName);
			} else {
			log.info("通道: {} , 设置比较器失败", queueName);
			return R.fail("操作失败");
			}

			for (int i = 0; i < 10; i++) {
			int randomNum = RandomUtil.randomInt(10);
			PriorityDemo data = new PriorityDemo();
			@@ -72,7 +63,7 @@
			PriorityDemo data = new PriorityDemo();
			data.setName(name);
			data.setOrderNum(orderNum);
			if (QueueUtils.removePriorityQueueObject(queueName, data)) {
			if (QueueUtils.removeQueueObject(queueName, data)) {
			log.info("通道: {} , 删除数据: {}", queueName, data);
			} else {
			return R.fail("操作失败");
			@@ -89,7 +80,7 @@
			public R<Void> get(String queueName) {
			PriorityDemo data;
			do {
			data = QueueUtils.getPriorityQueueObject(queueName);
			data = QueueUtils.getQueueObject(queueName);
			log.info("通道: {} , 获取数据: {}", queueName, data);
			} while (data != null);
			return R.ok("操作成功");