jjzjj

parallel_executor

全部标签

c# - 现有的类似于Parallel.For的LINQ扩展方法?

这个问题在这里已经有了答案:关闭9年前。PossibleDuplicate:LINQequivalentofforeachforIEnumerableienumerable的linq扩展方法非常方便……但如果您只想对枚举中的每个项目应用一些计算而不返回任何内容,那么就没那么有用了。所以我想知道也许我只是错过了正确的方法,或者它是否真的不存在,因为如果它可用的话我宁愿使用内置版本......但我还没有找到一个:-)我可以发誓某处有一个.ForEach方法,但我还没有找到它。与此同时,我确实编写了自己的版本以防它对其他人有用:usingSystem.Collections;usingSys

c# - 如果在单独的方法中调用,为什么 Parallel.Invoke 会快得多?

我执行了3次QuickSort-Algorithm并测量了对5000万个随机数进行排序的时间:顺序(大约需要14秒)使用Parallel.Invoke()作为排序算法的相同方法(耗时约12秒)使用Parallel.Invoke()在单独的方法中(耗时约7秒)所以我的问题是:如果在单独的方法中调用,为什么Parallel.Invoke()会快得多?在我的电脑上,示例3.的速度是示例2的两倍多。2。使用Parallel.Invoke()作为排序算法的相同方法publicclassParallelQuickSort{privateconstintThreshold=100;publicsta

c# - 支持 .NET 4.0 中的进度报告和增量结果 "Task Parallel Library"

我知道TaskParallelLibrary仍处于测试阶段,可用资源可能会减少,但从我所读的内容来看,图书馆对taskscheduling给予了非常特殊的对待。,exceptionhandling和cancellation.但我没有找到任何关于进度报告和发送增量结果的任务引用。这两件事似乎太重要了,不容忽视。您能否阐明如何在任务并行库中处理这些问题或引用一些解释它们的文章? 最佳答案 这个例子更新了一个进度条:usingSystem;usingSystem.Threading;usingSystem.Threading.Tasks;

c# - Parallel.ForEach 调试或逐步执行

是否有一种简单的方法来遍历parallel.foreach?使用断点进行调试的最佳方法是什么? 最佳答案 在调试期间,我经常将我的Parallel.ForEach设置为在MaxDegreeOfParallelism设置为1的情况下运行。这使得调试变得更加简单。constboolforceNonParallel=true;varoptions=newParallelOptions{MaxDegreeOfParallelism=forceNonParallel?1:-1};Parallel.ForEach(collection,opti

php - 为什么 suhosin.executor.disable_emodifier 不起作用?

我在ubuntu12.04上运行PHP5.6作为apache2.4模块Suhosin从源安装Suhosin已启用,我可以在phpinfo()函数输出中看到它。我在suhosin.ini中有这些行:suhosin.executor.disable_eval=Onsuhosin.executor.disable_emodifier=On而且我还可以看到它们在phpinfo()中启用。全局和本地。但出于某种原因很简单eval('echo5;');只给我看那个该死的“5”!!!同样如此preg_replace("/.*/e","eval('echo5,PHP_EOL;')",".");如何启用

java - 列出 ThreadPoolTask​​Executor 中所有正在运行/排队的线程

我在Spring中使用ThreadPoolTask​​Executor来安排我的任务。有没有办法获取该任务执行器/池的每个正在运行和排队的线程的列表或其他信息? 最佳答案 也许不是很优雅,但通过这种方式我可以从已知的执行器中获取所有线程(使用startsWith()前缀)。SetthreadSet=Thread.getAllStackTraces().keySet();for(Threadthread:threadSet){if(thread.getName().startsWith("MyExecutor")){System.ou

java - Thread 在这里比 Executor 更受青睐吗?

据我了解,Executors有助于处理runnable的执行。例如。当我有几个工作线程完成它们的工作然后终止时,我会选择使用执行程序。执行者将处理创建和终止执行工作线程所需的线程。但是现在我面临着另一种情况。固定数量的类/对象应封装自己的线程。因此线程在创建这些对象时启动,线程将在这些对象的整个生命周期内继续运行。少数对象依次在程序开始时创建并在整个运行时存在。我想在这种情况下线程比执行器更可取,但是当我阅读互联网时,每个人似乎都建议在任何可能的情况下使用执行器而不是线程。有人可以告诉我这里是选择Executors还是Threads,为什么?谢谢 最佳答案

java - Spark Driver 内存和 Executor 内存

我是Spark的初学者,我正在运行我的应用程序以从文本文件中读取14KB数据,进行一些转换和操作(收集、收集AsMap)并将数据保存到数据库我在我的macbook上本地运行它,它有16G内存,8个逻辑核心。Java最大堆设置为12G。这是我用来运行应用程序的命令。bin/spark-submit--classcom.myapp.application--masterlocal[*]--executor-memory2G--driver-memory4G/jars/application.jar我收到以下警告2017-01-1316:57:31.579[Executortasklaunc

java - 什么时候使用 Callable 对象在 Java Executor 中调用 call() 方法?

这是来自example的一些示例代码.我需要知道的是call()何时在可调用对象上被调用?是什么触发了它?publicclassCallableExample{publicstaticclassWordLengthCallableimplementsCallable{privateStringword;publicWordLengthCallable(Stringword){this.word=word;}publicIntegercall(){returnInteger.valueOf(word.length());}}publicstaticvoidmain(Stringargs[

java - 使用 Executors.newSingleThreadExecutor() 的优势

这个问题在这里已经有了答案:ThedifferencebetweenExecutors.newSingleThreadExecutor().execute(command)andnewThread(command).start();(6个答案)关闭9年前。使用的优势是什么Executors.newSingleThreadExecutor().submit(job);比job.run();其中job是Runnable类的一个实例。