按照公平原则执行任务
创始人
2024-08-24 02:30:21
0

可以使用Java中的ConcurrentLinkedQueue作为任务队列,每个任务都可以封装成一个Runnable对象,然后在另一个线程中执行这些任务。为了按照公平原则执行任务,可以在队列中使用Iterator遍历任务,并且为每个任务设置一个权重值,权重越高的任务会被先执行。

示例代码如下:

import java.util.Comparator;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.atomic.AtomicInteger;

public class FairTaskExecutor {

  private final ConcurrentLinkedQueue tasks = new ConcurrentLinkedQueue<>();
  private final AtomicInteger sequence = new AtomicInteger(0);

  /**
   * 添加任务到队列
   * @param task 任务
   * @param priority 权重值
   */
  public void addTask(Runnable task, int priority) {
    taskPriority = sequence.getAndIncrement() * 100 + priority;
    tasks.add(new PriorityRunnable(task, taskPriority));
  }

  /**
   * 执行任务
   */
  public void executeTasks() {
    Runnable task;
    while ((task = tasks.poll()) != null) {
      task.run();
    }
  }

  /**
   * 带有优先级的Runnable
   */
  private class PriorityRunnable implements Runnable, Comparable {
    private final Runnable task;
    private final int priority;

    public PriorityRunnable(Runnable task, int priority) {
      this.task = task;
      this.priority = priority;
    }

    @Override
    public void run() {
      task.run();
    }

    @Override
    public int compareTo(PriorityRunnable other) {
      return Integer.compare(priority, other.priority);
    }
  }

}

使用示例:

// 创建任务执行器
FairTaskExecutor executor = new FairTaskExecutor();

// 添加任务
executor.addTask(() -> System.out.println("Task 1 - Low Priority"), 1);
executor.addTask(() -> System.out.println("Task 2 - High Priority"), 10);
executor.addTask(() -> System.out.println("Task 3 - Medium Priority"), 5);

// 按照公平原则执行任务
executor.executeTasks();
``

相关内容

热门资讯

实测揭晓“家家盘锦开挂”hh ... 实测揭晓“家家盘锦开挂”hh poker软件(本来是真的有挂);小薇(透视辅助)致您一封信;亲爱家家...
黑科技辅助挂!(WPK)其实真... 黑科技辅助挂!(WPK)其实真的有挂,(wpK)切实存在有挂,安装教程(有挂透明挂)1、wpK系统规...
玩家必看分享“开心十三水辅助工... 1、玩家必看分享“开心十三水辅助工具”pokerworld破解版下载(切实是真的有挂);详细教程。2...
黑科技辅助挂!WpK透视辅助,... 黑科技辅助挂!WpK透视辅助,Wpk透视ai辅助,2025教程(有挂神器);1、全新机制【WpK软件...
一秒答解“微乐卡五星有挂吗”w... 一秒答解“微乐卡五星有挂吗”wepoker轻量版透视系统(都是真的是有挂)这是由厦门游乐互动科技有限...
黑科技辅助挂!智星德州菠萝辅助... 黑科技辅助挂!智星德州菠萝辅助器工具,智星德州辅助神器,我来教教你(有挂助手)运智星德州菠萝辅助工具...
黑科技辅助挂!(智星德州)其实... 黑科技辅助挂!(智星德州)其实是真的有挂,(智星菠萝德州)一贯有挂,新2025教程(有挂攻略)1、在...
玩家必备科技“潮汕汇木虱鱼辅助... 1、玩家必备科技“潮汕汇木虱鱼辅助”hhpoker可以控制牌吗(都是真的有挂);详细教程。2、潮汕汇...
黑科技辅助挂!智星菠萝德州辅助... 黑科技辅助挂!智星菠萝德州辅助器工具,智星菠萝德州辅助器,辅助教程(有挂软件)1、完成智星菠萝德州透...
揭秘真相“微信微乐开挂”wpk... 揭秘真相“微信微乐开挂”wpk刷入池率脚本(先前是有挂)1、点击下载安装,微扑克wpk插件透视分类一...