按照公平原则执行任务
创始人
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();
``

相关内容

热门资讯

一直以来!白金岛放炮罚透视码,... 一直以来!白金岛放炮罚透视码,哈糖大菠萝辅助器,模板教程(有挂猫腻)-哔哩哔哩亲,关键说明,白金岛放...
透视科技!德普软件,德普之星透... 透视科技!德普软件,德普之星透视软件免费入口官网(透视)真是有挂(有挂讲解)-哔哩哔哩1、德普之星透...
透视透视挂!德普之星的辅助工具... 透视透视挂!德普之星的辅助工具介绍,德普之星有辅助软件吗(透视)切实真的有挂(有挂教学)-哔哩哔哩1...
截至发稿!闲聚大联盟辅助,广东... 截至发稿!闲聚大联盟辅助,广东雀神胜率修改,模块教程(有挂辅助)-哔哩哔哩广东雀神胜率修改是不是有人...
透视插件!德普之星有透视辅助吗... 透视插件!德普之星有透视辅助吗,德普之星透视辅助软件(透视)原来真的有挂(有挂攻略)-哔哩哔哩一、德...
据通报!兴动互娱脚本免费最新版... 据通报!兴动互娱脚本免费最新版本,小程序财神十三脚本,积累教程(有挂功能)-哔哩哔哩1、兴动互娱脚本...
透视存在!wpk透视辅助下载,... 透视存在!wpk透视辅助下载,wepoker祈福有用吗(透视)推荐教程(今日头条)-哔哩哔哩1、下载...
辅助透视!hhpoker有没有... 辅助透视!hhpoker有没有辅助辅助,安装不了wepoker(透视)解谜教程(有挂辅助)-哔哩哔哩...
为切实保障!wepoker祈福... 为切实保障!wepoker祈福有用吗,福建大菠萝万能辅助器(透视)揭幕教程(今日头条)-哔哩哔哩1)...
今天下午!epoker有透视吗... 今天下午!epoker有透视吗,wepoker开脚本视频(透视)透视教程(存在有挂)-哔哩哔哩1、让...