草庐IT

trap-executor

全部标签

具有节流/吞吐量控制的 Java Executor

我正在寻找一个JavaExecutor,它允许我指定节流/吞吐量/步调限制,例如,一秒钟内最多可以处理100个任务——如果提交了更多任务,它们应该排队并且后执行。这样做的主要目的是避免在访问外部API或服务器时遇到限制。我想知道是否是基础Java(我怀疑,因为我检查过)或其他可靠的地方(例如ApacheCommons)提供了这个,或者我是否必须自己编写。最好是轻量级的。我不介意自己写,但如果有一个“标准”版本,我至少想先看看它。 最佳答案 看看GuavaRateLimiter:Aratelimiter.Conceptually,ar

java - ExecutorService.submit(Task) vs CompletableFuture.supplyAsync(Task, Executor)

要并行或异步运行一些东西,我可以使用ExecutorService:Futuresubmit(Runnabletask,Tresult);或CompletableFutureAPI:staticCompletableFuturesupplyAsync(Suppliersupplier,Executorexecutor);(假设我在这两种情况下都使用同一个Executor)除了返回类型Future与CompletableFuture有什么显着差异。或者什么时候用什么?如果我使用CompletableFuture有什么区别?默认APIExecutor(没有执行者的方法)?

java - ExecutorService.submit(Task) vs CompletableFuture.supplyAsync(Task, Executor)

要并行或异步运行一些东西,我可以使用ExecutorService:Futuresubmit(Runnabletask,Tresult);或CompletableFutureAPI:staticCompletableFuturesupplyAsync(Suppliersupplier,Executorexecutor);(假设我在这两种情况下都使用同一个Executor)除了返回类型Future与CompletableFuture有什么显着差异。或者什么时候用什么?如果我使用CompletableFuture有什么区别?默认APIExecutor(没有执行者的方法)?

Spring ThreadPoolTask​​Scheduler vs ThreadPoolTask​​Executor

在Springdocumentation中提到那:ThreadPoolTaskScheduleractuallyimplementsSpring'sTaskExecutorinterfaceaswell,sothatasingleinstancecanbeusedforasynchronousexecutionassoonaspossibleaswellasscheduled,andpotentiallyrecurring,executions.那么我们希望在哪些场景中使用ThreadPoolTask​​Executor实例而不是ThreadPoolTask​​Scheduler实例?

Spring ThreadPoolTask​​Scheduler vs ThreadPoolTask​​Executor

在Springdocumentation中提到那:ThreadPoolTaskScheduleractuallyimplementsSpring'sTaskExecutorinterfaceaswell,sothatasingleinstancecanbeusedforasynchronousexecutionassoonaspossibleaswellasscheduled,andpotentiallyrecurring,executions.那么我们希望在哪些场景中使用ThreadPoolTask​​Executor实例而不是ThreadPoolTask​​Scheduler实例?

ios - 如何优化 mach_msg_trap

我知道之前有人问过这个问题,但没有人就如何解决这个问题给出任何有用的答案。我有一个使用box2d物理引擎的cocos2dios应用程序。我对其进行了性能测试,CPU将5.6%的时间花在了mach_msg_trap上。从我从其他问题中收集到的信息来看,似乎mach_msg_trap只是由于您的应用程序空闲而导致的主线程浪费时间。我的应用程序并没有闲置。它的性能不稳定,徘徊在50fps区域。有什么方法可以配置它以获得额外的性能吗?还是这只是我编写的一些错误代码的结果?如果是,我该如何优化它?我正在第二代ipodtouch上测试调试版本的性能。这可能是问题的一部分。我在sprite批处理中对

java.lang.LinkageError : loader constraint violation: when resolving method "org. jboss.resteasy.client.core.executors.ApacheHttpClient4Executor 错误

JSF网络应用程序尝试从JavaEE网络服务检索资源。JSF网络应用程序运行良好。由于我添加了Http客户端源来检索JBoss实例声明的Web服务资源:15:29:47,689SEVERE[javax.enterprise.resource.webcontainer.jsf.application](http--0.0.0.0-443-1)ErrorRenderingView[/index.xhtml]:javax.el.ELException:/surfaceParts/sideBarLeft.xhtml@14,79value="#{categories.cats}":java.la

java - Spring ThreadPoolTask​​Executor 中的 corePoolSize 和 maxPoolSize 有什么区别

我必须向网站的所有用户发送大量电子邮件。我想为每封发送的电子邮件使用一个线程池。目前我已将值设置为:两者之间有什么区别,是否会扩展。目前我有大约。10000个用户。 最佳答案 以下是Sun的线程创建规则,简单来说:如果线程数小于corePoolSize,则创建一个新线程来运行一个新任务。如果线程数等于(或大于)corePoolSize,则将任务放入队列。如果队列已满,并且线程数小于maxPoolSize,则创建一个新线程来运行任务。如果队列已满,且线程数大于等于maxPoolSize,则拒绝该任务。FullarticleOrigin

java - Spring ThreadPoolTask​​Executor 中的 corePoolSize 和 maxPoolSize 有什么区别

我必须向网站的所有用户发送大量电子邮件。我想为每封发送的电子邮件使用一个线程池。目前我已将值设置为:两者之间有什么区别,是否会扩展。目前我有大约。10000个用户。 最佳答案 以下是Sun的线程创建规则,简单来说:如果线程数小于corePoolSize,则创建一个新线程来运行一个新任务。如果线程数等于(或大于)corePoolSize,则将任务放入队列。如果队列已满,并且线程数小于maxPoolSize,则创建一个新线程来运行任务。如果队列已满,且线程数大于等于maxPoolSize,则拒绝该任务。FullarticleOrigin

hadoop - Apache spark 1.2.1 独立集群中的剂量, 'number of executors equals to number of SPARK_WORKER_INSTANCES'?

Apachespark1.2.1Standalone集群中的Dose,“执行程序的数量等于SPARK_WORKER_INSTANCES的数量”?Ihavedonebelowsettinginconf/spark-env.shSPARK_EXECUTOR_CORES=4SPARK_NUM_EXECUTORS=3SPARK_EXECUTOR_MEMORY=2G如果没有,谁能告诉我如何增加独立集群中的执行程序数量?提前致谢。 最佳答案 在独立模式下,总执行器数量等于集群中的总工作器数量。spark-env.sh中的SPARK_WORKER