我正在尝试编写一个单线程执行器，它在调度任务并基于PriorityBlockingQueue执行任务时返回一个CompletableFuture。我的任务看起来像这样： } HIGH,
浏览 52提问于2020-02-23得票数 2
回答已采纳
TL;DR:当几个CompletableFuture__s在等待被执行时，我如何才能优先处理那些我对__感兴趣的值的？我有一个10,000个CompletableFuture的列表(用于计算产品数据库上的内部报表的数据行)：我注意到ThreadPoolExecutor使用Block
浏览 8提问于2020-08-08得票数 8
我试图通过ThreadPoolExecutor向现有应用程序添加一个优先级队列，该应用程序通过LinkedBlockingQueue通过CompletableFuture.supplyAsync使用CompletableFuture.supplyAsync问题是，我无法提出一个设计来分配任务优先级，然后可以在PriorityBlockingQueue的比较器中访问这些优先级。这是因为我的任务被CompletableFuture包装成一个名为AsyncSupply
浏览 15提问于2016-01-19得票数 6
回答已采纳
当我阅读的源代码时，我认为DelayQueue只是PriorityBlockingQueue的一个特例，因此可以通过在内部包装一个PriorityBlockingQueue来简单地实现DelayQueue所以我的问题来了，为什么DelayQueue不在内部使用PriorityBlockingQueue？DelayQueue和PriorityBlockingQueue有什么不同
浏览 6提问于2017-04-24得票数 0
我有一个非常简单的程序： class MyThread2 implements2, 1, new PriorityBlockingQueue(new MyThread2());
executor.submit(new MyThread2(
浏览 18提问于2022-07-06得票数 1
回答已采纳
一般来说，问题是为什么我应该选择使用PriorityBlockingQueue而不是PriorityQueue。PriorityBlockingQueue
static PriorityBlockingQueue<String> priorityQueue = new PriorityBl
浏览 0提问于2013-05-22得票数 9
回答已采纳
我试图解决生产者/消费者的问题，但我不知道为什么我要让java.lang.NullPointerException进入消费者。package com ;
System.out.println("Error");
浏览 4提问于2012-09-20得票数 1
回答已采纳
我正在尝试做一个优先的ThreadPoolExecutor。ThreadPoolExecutor(30, MAXPOOL, MAXPOOL, TimeUnit.SECONDS, 所以现在的关键是队列引用但当我宣布：
static PriorityBlockingQueue<mDownloadThread> queue=new PriorityBlockingQueue<mDownloadThread>(MAXPOOL,new
浏览 4提问于2011-10-17得票数 6
回答已采纳
1回答
这意味着我必须支持以下功能：跟踪“工件名称”、版本和我们解析的实际URL。 private static Executor workers;
private static final PriorityBlockingQueue<ResolutionTask> taskQueue =
浏览 0提问于2017-06-09得票数 5
,9), new Items("pen",12)我的物品课private String IName;//constructor, getter and setter here我想将每个对象插入到一个PriorityBlockingQueue因此，PriorityBlockingQu
浏览 3提问于2022-07-19得票数 0
我正在使用java和Spring IOC框架。我正在处理一个现有的应用程序，并且需要对某段代码进行更改<bean name="SymQ" class="java.util.concurrent.PriorityBlockingQueueprivate PriorityBlockingQueue<String> SymQ;
有没有可能用一些预定义的值来初始化SymQ。例如，我需要具有一些预定义的值的
浏览 1提问于2013-07-23得票数 0
回答已采纳
我在一些代码中使用ThreadPoolExecutor，并为它提供了一个BlockingQueue<Runnable>。我得到一个编译器错误说can't resolve constructor。但是，通过ThreadPoolExecutor的构造函数，我得到了一个编译器错误：public class Test {
浏览 2提问于2014-09-16得票数 1
回答已采纳
1回答
threadPool = 优先级排序的关键是队列参数基本上我需要一个PriorityBlockingQueue，所以我使用构造函数：queue = new PriorityBlockingQ
浏览 2提问于2012-08-20得票数 0
回答已采纳
在我的android应用程序中，我在同步块中使用PriorityQueue，那么线程安全吗？我无法找到我问题的答案。Android本身说“PriorityQueue不是同步的，如果多个线程需要并发访问它，请使用PriorityBlockingQueue”。我们在同步块中编写的东西是线程安全/同步。所以，我使用的方法是正确的还是需要实现PriorityBlockingQueue？请帮帮我。提
浏览 4提问于2014-02-27得票数 0
回答已采纳
1回答
摘要我不知道最好的方法(无错误和最快)让消费者睡觉，然后再唤醒它。电流码
目前我使用的是一个简单的信号量。selector，让使用者
浏览 1提问于2016-12-23得票数 1
可能重复：
，这是我的制作人班。。package com ;
这是我的客户程序
import java.util.concurrent.<e
浏览 5提问于2012-09-20得票数 2
回答已采纳
我正在使用thread pool executor，我观察到当我使用PriorityBlockingQueue时，它会在下面的代码中抛出ClassCastException，如果我在下面的代码中选择LinkedBlockingQueue而不是PriorityBlockingQueue，一切都会正常工作。{
ThreadPoolExecutor executor = new ThreadPoolExecutor(1, 1, 10, TimeUnit.MINUTES, new PriorityB
浏览 24提问于2017-06-16得票数 0
回答已采纳
1回答
RXJava线程优先级
、、、
我使用以下方法获取订阅的ExecutorService： return Schedulers.from(mBackgroundExecutorService);我在后台运行的可观测数据中使用了这个计划问题
如何将PriorityBlockingQueue用于RXJa
浏览 3提问于2016-02-22得票数 3
现在，我不希望在队列中没有数据时停止使用者的运行，而只是希望它等到有数据时再继续执行它。因此，我希望使用者在我的应用程序的整个持续时间内运行，因为队列中随时可能有请求。只有一种方法可以添加到队列中，那就是通过Producer类的特定函数。因此，为了确保当队列有一些数据时，Consumer自动启动，我在生产者的consructor中创建了consumer类对象，并将其传递给空队列，目的是等待一些数据被放入队列中，然后将其拉出并在队列上执行其工作我的印象是
浏览 0提问于2014-07-16得票数 0
2回答
我需要创建我自己的PriorityBlockingQueue<Runnable>实现1- classMyQueue<T extends MyRunnableInterface> extends PriorityBlockingQueue<T>
2- class MyQueue extends PriorityBlockingQueue使用
浏览 1提问于2014-08-12得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
