java并行流可以在单个线程中处理相关任务吗？
是的，Java并行流可以在单个线程中处理相关任务。Java并行流是Java 8引入的一种并行处理数据流的方式，它可以将一个数据流分成多个子流，并行地对每个子流进行操作，最后将结果合并。在单个线程中，Java并行流会使用Fork/Join框架来实现任务的划分和合并。
使用Java并行流可以提高处理大数据集的效率，特别是在多核处理器上。它适用于需要对数据进行并行处理的场景，例如对集合进行过滤、映射、排序等操作。通过并行流，可以将任务分配给多个线程同时执行，从而加快处理速度。
在腾讯云的产品中，推荐使用云函数（SCF）来处理Java并行流任务。云函数是一种无服务器计算服务，可以根据实际需求自动弹性地分配计算资源。您可以使用云函数来编写和运行Java代码，实现并行流任务的处理。您可以通过腾讯云云函数产品页面（https://cloud.tencent.com/product/scf）了解更多关于云函数的信息和使用方法。
相关·内容
在Java SDK8中，Collection类附带了一个新方法"parallelStream“。
很明显，这个新方法提供了一种并行使用集合的机制。
但是，我想知道Java是如何实现这种并行性的。潜在的机制是什么？这是一个简单的多线程执行吗？或者，fork/join框架(随Java SDK 7提供)会介入吗？如果答案是两者都不是，那么它是如何工作的，它相对于其他两种机制的优势是什么？
浏览 1提问于2014-07-08得票数 3
我想了解更多关于StreamThread、StreamTask之间的关系以及当我们创建了多少StreamProcessor实例时的一些细节：
一个包含多个分区的源kafka主题，比如6. (num.stream.threads=1) --我只保留ONE StreamThread
我保持一个简单的处理器拓扑：
source_topic -> Processor1 --> Processor2 --> Processo3 --> sink_topic
每个处理器简单地转发到链中的下一个处理器。其中一个处理器的片段。我正在使用低级别的Java。
public class P
浏览 2提问于2020-02-09得票数 3
回答已采纳
我读过一本关于Java 8的书，书中说，使用并行流通过IntStream.range(0,someNumber)获取数字范围可能比顺序one...why慢，是吗？
浏览 13提问于2015-05-02得票数 0
回答已采纳
3回答
所以，我试着了解一下Java 8中引入的Stream。我试图创建一个可以在单独的线程上运行的流(只是为了教育目的)
String oracle = "http://www.oracle.com";
URL url = new URL(oracle);
BufferedReader in = new BufferedReader(new InputStreamReader(url.openStream()));
in.lines().parallel().forEach(System.out::println);
System.out.print("CLOSING THE
浏览 3提问于2016-03-20得票数 5
回答已采纳
1回答
我是第一次学习SSIS。我正在尝试将多个表从我的临时数据库加载到数据仓库中的多个表。我的临时数据库只是一个将所有源数据库中的所有表复制到其中的数据库。我发现每个数据流任务只允许将一个源表连接到一个目标表。我是否必须使用与我的源数据库中的表数一样多的数据流任务？有没有更简单、更有效的方法来做到这一点呢？
根据我的理解，我需要一个空数据库，其中包含在SQL Server中创建的空Dim表和事实表，它将充当目标数据仓库，并从临时数据库接收数据。因此，我已经创建了这个空的数据仓库。请帮帮忙。
浏览 1提问于2013-04-15得票数 0
回答已采纳
1回答
多线程EJB客户端
、、、、
我希望并行化来自java客户端的多个ejb调用，并维护单个事务。ejb是在websphere应用服务器上公开的，而客户机是部署在同一was上的一个简单的春季引导war。我能够在顺序流中维护事务，现在我想并行化这个调用流。这个是可能的吗？
浏览 2提问于2022-04-07得票数 0
我从一本烹饪书中了解到，单词之间的主要区别是:并行和并发。
并行:使用多个核心/CPU处理多个任务
并发性:使用一个核心/ CPU处理多个任务，但使用时间框架机制。
因此，我还了解到，Java是一种使用多个核的强大功能同时实现多个任务处理的语言。但是它在此功能上的包名称为java.util.concurrency。
为什么java使用并发一词而不是并行？
浏览 15提问于2021-08-10得票数 0
回答已采纳
处理程序消息队列是如何工作的？我知道的一个事实是，消息队列被绑定到初始化它的线程。如果我有两个任务(每个任务都是从web上下载的)，并且我从处理程序中启动了一个异步任务，每个任务一个，这两个任务是否会同时执行？
我只需要理解队列是如何工作的..谁能帮帮忙！:)
浏览 1提问于2012-10-12得票数 0
回答已采纳
1回答
我想要实现的是，我在MaxDegreeOfParallelism = 4上有一个动作块。我想为每个并行路径创建一个会话对象的本地实例，所以我希望总共有4个会话对象。如果这是线程，我会创建类似这样的东西：
ThreadLocal<Session> sessionPerThread = new ThreadLocal<Session>(() => new Session());
我知道块不是线程，所以我在寻找类似的东西，而是块。有什么方法可以创建这个吗？
此块处于服务中，并连续运行了几个月。在此期间，块的每个并发插槽都使用了大量线程，因此线程本地存储并不合适。我需要
浏览 0提问于2013-03-07得票数 1
1回答
我有连续的消息。每条消息都有一个键(在我的例子中，我使用locale作为键)。我需要一些类型的执行器，允许我把这个消息放在不同的队列中的关键字，并在并行线程中处理队列。java有没有适合我的情况？或者也许谷歌芭乐做到了？大概是这样的：
Executor<K, T> {
Map<K, LinkedList<T>> groupedTasks;
void submit(K key, T task);
}
浏览 0提问于2016-09-28得票数 2
2回答
我一直在学习Java 8的并行流，出现在谷歌搜索的第一页。我无法从这篇文章中理解这句话。
...all并行流使用公共的叉-连接线程池，如果您提交了一个长期运行的任务，则可以有效地阻止池中的所有线程()。
我不知道长时间运行的任务如何阻塞池中的所有其他线程。
浏览 0提问于2018-02-01得票数 5
回答已采纳
1回答
我一直在阅读这个关于并行流的。这是相当长的喘息，我理解一切，直到一个部分，有关平行流如何工作。我将引用我难以理解的部分：
“并行化需要:执行子任务的线程池，将初始任务划分为子任务，将子任务分配给线程，整理结果。不输入详细信息，所有这些都意味着一些开销。当：
某些任务意味着长期阻塞，例如访问远程服务或
同时运行的线程不多，特别是没有其他并行流。
如果所有子任务都意味着密集的计算，则潜在的增益将受到可用处理器数量的限制。默认情况下，Java 8将使用计算机上的处理器一样多的线程，因此，对于密集的任务，结果在很大程度上取决于其他线程可能同时做什么。当然，如果每个子任务本质上都在等待，
浏览 1提问于2017-06-17得票数 2
回答已采纳
1回答
池中的最优线程是特定于情况的线程，尽管有一个，它表示#thread.join= #CPU +1。然而，如何处理跨越其他线程的线程，并等待这些“子线程”(即阻塞直到thread.join()成功)？
假设我的代码需要执行任务列表(2)，其中有子任务(2)，有子任务(3)等等。任务总数为2*2*3 = 12，但将创建18个线程(因为一个线程将“生成”更多子任务(线程)，其中生成更多线程的线程将被阻塞，直到所有线程结束。伪代码见下文。
我假设对于有N个核的CPU来说，如果活动线程(12)的最高数量是#CPU + 1，那么所有事情都可以并行化。这是正确的吗？
PseudoCode
outputOfTa
浏览 1提问于2020-04-03得票数 1
回答已采纳
2回答
随着Join/Fork framework的出现，Java中只有Java 7才有可能进行并行编程。
假设在Java中，使用ExecutorService，我创建了一个线程池，比如4个线程，然后向它提交10个任务，这意味着4个线程将开始执行这4个任务，而其他6个任务将在任何线程完成其任务时被线程捕获。
让我们假设我有一个具有4个内核的四处理器，我知道一个线程可以在单个内核上运行(这里不考虑超线程概念)，那么我所有的4个线程是否都能并行工作，一个线程运行在一个内核上？这不是一个并行编程吗？
编辑： --这是Java8播放列表，在第1章中提到，从Java7开始就可以进行并行编程。
浏览 2提问于2017-07-04得票数 3
回答已采纳
最近，我在一个论坛上看到了一些评论，主题是绿色线程可能很便宜，但对于CPU绑定的并发任务却不太好。他们给出了一个例子，说明在CPU绑定任务中使用goroutines比使用原始线程(OS级线程)的C/Java/Rust等效任务要慢得多。
我知道绿色线程在IO绑定任务的效率方面是很好的。但我不知道它们并不适合CPU绑定任务。这是真的吗？如果是，为什么？
浏览 5提问于2022-08-19得票数 1
2回答
我想在全局替换Java并行流默认使用的公共线程池，例如
IntStream.range(0,100).parallel().forEach(i -> {
doWork();
});
我知道，可以通过向专用线程池提交这样的指令来使用专用的ForkJoinPool (参见 )。这里的问题是
是否可以用其他实现(例如，ForkJoinPool )来替代普通的Executors.newFixedThreadPool(10)？
是否可以通过一些全局设置(例如，一些JVM属性)来做到这一点？
备注:我之所以喜欢替换F/J池，是因为它似乎有一个错误，这使得它不能用于嵌套的并行循
浏览 4提问于2014-05-09得票数 8
1回答
我正在研究并行编程和测试这个蛮力代码，以破解一个密码，有7个位置没有并行性，但当应用并行编程时，代码运行速度比以前慢。有人知道为什么吗？如何在这段代码中使用并行编程使其更快？谢谢。
public class Worker extends Thread{
private static final int[] valuesCaracter = {48, 48, 48, 48, 48, 48, 48};
private static final int arraySize = valuesCaracter.length;
private static char[] symbols = new ch
浏览 7提问于2022-05-02得票数 0
我在某个地方看到了使用stream().map().reduce()的代码。
这个map()函数真的可以并行工作吗？如果是，那么它可以为map()函数启动多少个最大线程数？
如果我使用parallelStream()，而不是只对下面的特定用例使用stream()，该怎么办？
有人能给我举个例子，说明在什么地方不使用parallelStream()吗？
下面的代码只是从tName中提取tCode并返回逗号分隔的字符串。
String ts = atList.stream().map(tcode -> {
return CacheUtil.getTCache().getTIn
浏览 1提问于2017-06-28得票数 1
回答已采纳
2回答
我有几个计算密集型的方法，我试图使用异步等待并行运行。
我有一个大约80,000个对象的列表，我将这些对象输入一个返回任务的函数中：
public static void Main(string[] args)
{
//...blah blah blah...
var runner = new Runner(); //in a nutshell, I manage to get an object that has an async method on it.
runner.Run().Wait(); //and I wait for it to complete.
浏览 0提问于2014-09-17得票数 1
回答已采纳
1回答
lscpu的输出(包括部分输出)： CPU(s): 12
On-line CPU(s) list: 0-11
Thread(s) per core: 1
Core(s) per socket: 6
Socket(s): 2
NUMA node(s): 2 我只想确认我的理解是正确的： (1)我有12个CPU(s)/cores。这个数字也是我拥有的硬件线程的数量。 (2)如果(1)为真，假设我运行的代码使用了12个以上的软件线程，这将导致超额订阅。假设我使用了13个软件线程，这是否意味着我的一个软件线程不能
浏览 26提问于2019-04-06得票数 0
回答已采纳
4回答
我有一个spring应用程序，它根据请求上下文注入某些bean。在本例中，它是Facebook。
@RestController
@RequestMapping("facebook")
public class FacebookInjectionController {
@Autowired
private Facebook facebook;
@Autowired
private UserRepository userRepository;
@RequestMapping(method = RequestMethod.GET)
浏览 0提问于2017-02-09得票数 4
我正在处理一批100个对象，将它们分割成10个分区，每个分区被发送到一个单独的线程，并行处理。这是当前的代码：
1. var itemsToSave = new ConcurrentLinkedQueue<ItemToSave>();
2
3. Lists.partition(originalList, 10)
4. .parallelStream()
5. .forEach(partitionedList -> process(partitionedList, itemsToSave));
我的理解是
line1: creates a thread safe list
浏览 11提问于2022-07-22得票数 2
我有一个并行流，里面有一些数据库查询，如下所示：
private void processParallel() {
List\<Result\> = objects.parallelStream().peek(object -\> {
doSomething(object)
}
}
private void doSomething(object) {
CompletableFuture<String> param =
CompletableFuture.supplyAsync(() -> objectService.getParam(obj
浏览 5提问于2022-11-07得票数 0
我对图形处理器上的CUDA或OpenCL代码的并行性有一个一般性的问题。我使用的是NVIDIA GTX 470。
我在Cuda编程指南中简短地阅读了一下，但没有找到相关的答案，因此在这里提问。
我有一个顶级函数，它调用CUDA内核(对于相同的内核，我有它的OpenCL版本)。对于3个不同的数据集(图像数据R，G，B)，这个顶级函数本身在主函数的“for循环”中被调用了3次，而实际的codelet也对图像/帧中的所有像素进行了处理，因此它有2个“for循环”。
我想知道的是这里使用了哪种并行性-任务级并行还是数据并行？
所以我想要了解的是，CUDA和C代码是否为代码集和顶级代码中的不同功能/函数
浏览 1提问于2011-12-22得票数 4
回答已采纳
有办法提高AsyncTask的优先级吗？
我正在AsyncTask中做一些图像处理。在一个非常慢的设备上，处理图像需要60秒的时间。现在我想通过提升任务的优先级来提高性能。能做点什么吗？
浏览 2提问于2016-02-03得票数 6
回答已采纳
2回答
我有一个大约10 GB的大文件。我必须在Java中对文件进行排序、过滤等操作。每个操作都可以并行完成。
启动10个线程并并行读取文件好吗？每个线程读取1 GB的文件。有没有其他方法可以解决超大文件的问题并尽可能快地处理它们？NIO适用于这样的场景吗？
目前，我正在串行执行操作，大约需要20分钟来处理这样的文件。
谢谢,
浏览 6提问于2012-03-15得票数 8
回答已采纳
8回答
我在Google上做了一些研究，我不能完全理解java中并发程序和并行程序之间的区别(如果有的话)。我看过的一些信息表明两者之间没有区别。是这样的吗？？
浏览 0提问于2013-01-03得票数 35
我已经开发了一个将解析JSON数据并在ListView中显示结果的活动。为此，我使用了一个AsyncTask。
我现在想要的是，当我点击ListView中的一个项目时，文件应该开始下载。我是否可以在相同的活动中编写另一个AsyncTask，以便该AsyncTask可以为我完成下载工作？在同一个活动中有多个AsyncTasks有什么问题吗？
浏览 1提问于2015-03-09得票数 14
回答已采纳
是否有一种简单的方法可以在java 8中使用一些库来并行一个foreach循环？
void someFunction(SomeType stuff, SomeType andStuff) {
for (Object object : lotsOfObjects)
object.doSomethingThatCanBeDoneInParallel(stuff, andStuff);
}
多线程是有点痛苦和耗时，所以我想知道是否有一个更简单的方法来做上述使用某些库。
谢谢。
2018年6月3日编辑
ExecutorServices非常方便--事实上，我不能使用wait ()
浏览 0提问于2018-05-12得票数 0
回答已采纳
我在一个应用程序(java)中看到它在Solaris框中有不规则的内存使用。当我抛出一个线程时，我看到有31个"GC任务线程“.
这非常奇怪，因为在其他Solaris框中，同一个应用程序只有2个"GC任务线程“。
想知道是否有人知道，在哪种情况下，jvm会创建这么多GC任务线程，这会导致内存问题吗？
任何想法都会受到赞赏。
更多关于我的案例的背景介绍:每次我将在同一个框中同时运行两个类似的Java应用程序。我将继续向应用程序A发送请求，而不向应用程序B发送请求。因此，应用程序B应该处于活动状态。当使用prstat时，它总是“睡眠”。
奇怪的是，在一个Solaris框中，应用程序
浏览 2提问于2011-11-03得票数 1
我有一个活动(MainActivity)，它使用HttpURLConnection来使用AsyncTask上传文件。一切都很好很好。我还有另一个活动(ListAllFilesActivity)，它使用带有makeHttpRequest的JSONParser查询MySQL数据库，以获取已上载的所有文件的列表(也使用AsyncTask)。ListAllFilesActivity活动也非常有效。
我遇到的问题是，如果我从MainActivity开始一个大文件的文件上载，然后启动ListAllFilesActivity来查询数据库，数据库查询将不会返回结果，直到AsyncTask MainActivi
浏览 3提问于2013-08-01得票数 0
回答已采纳
1回答
多个带有取消请求的http请求
、、、、
我正在创建一个android应用程序，它需要一些并行的HTTP/HTTPS请求(确切地说是10)。
第一步
我如何在android中提出这个并行请求？
可以同时使用HTTP和HTTPS吗？
Obs:在谷歌搜索，我找到了ExecutorService。我能在android上用这个吗？(有人有例子吗？)
第二步
如果有人在第一个问题上提供帮助，我将有以下情况：
1 request one started -- (working) --> cloud
2 request two started -- (working) --> cloud
3 request three star
浏览 0提问于2014-09-06得票数 1
回答已采纳
前几天，我遇到了一个问题，我将工人的SetNumberOfWorkers缩放到一个可笑的数字，期望看到吞吐量的同等增长。我只能看到5名工人一次做任何工作。算出魔法上限是最大并行选项，默认值是5。
我的假设是，一个工人等于一个线程。
NumberOfWorkers和MaxParallelism选项的目的或关系是什么？
浏览 1提问于2016-01-05得票数 4
回答已采纳
我在一个3节点的纱线集群上运行了一个星火流(createStream API)应用程序，其中每个节点都有128 each (!)该应用程序读取卡夫卡主题的记录并写入HDFS。
大多数情况下，应用程序由于Java堆错误而失败/被杀死(大部分是接收方失败)，不管我为executor/驱动程序配置了多少内存。
16/11/23 13:00:20 WARN ReceiverTracker: Error reported by receiver for stream 0: Error handling message; exiting - java.lang.OutOfMemoryError: Java
浏览 2提问于2016-11-23得票数 0
回答已采纳
5回答
顺序流和并行流在Java1.8中的功能区别是什么，以及输出将如何受到影响？
以及在哪种场景中选择并行流还是顺序流？
顺序流和并行流在Java中的处理方法差异是什么？！！
我在下面的片段中尝试用少量的数据来测试它，在输出方面没有任何异常的差别。！！
ArrayList<Integer> arrayList = new ArrayList<>();
for(int i = 1; i <= 100;i++) arrayList.add(i);
arrayList.stream().filter(l -> l > 90).forEach(l -> Sy
浏览 5提问于2017-12-24得票数 5
回答已采纳
1回答
我试图使用生成随机值，特别是它对流的支持。理想情况下，应该以常数的方式生成值，这样流就可以是无限的：
SecureRandom secureRandom = new SecureRandom();
Iterator<Integer> idIterator = secureRandom.ints().distinct().iterator();
文档指出"__SecureRandom对象对于多个并发线程的使用是安全的。“但是，当多个线程从迭代器中检索下一个值时，我(至少)在其中一个线程中得到一个错误，该错误似乎是由于竞争条件造成的：
Thread t1 = new Threa
浏览 7提问于2020-12-02得票数 3
回答已采纳
2回答
从这篇中，我只能部分地了解到，至少在某种程度上，java嵌套并行流存在问题。然而，我无法推导出以下问题的答案：
假设我有一个外部srtream和一个内部流，这两个流都使用并行流。事实证明，根据我的计算，如果内部流首先完全并行完成，然后(如果只有CPU核心可用)完成外部流，性能会更好(由于数据局部性，即缓存在L1/L2/L3 cpu缓存中)。我认为这对大多数人的情况都是正确的。所以我的问题是：
Java会先并行执行内部流，然后再在外部流上工作吗？如果是这样，它是在编译时还是在运行时做出决定？如果在运行时，JIT是否足够聪明地意识到，如果内部流确实有超过足够的元素(例如数百个)而不是核心数( 32
浏览 0提问于2017-08-08得票数 1
顺序vs并发与并行vs分布式vs同步vs异步vs客户端-服务器与OSI模型
我明白..。
顺序的、并发的、并行的和分布的似乎都在同一个类中。
同步和异步在同一个类中(不同类型的输入/输出)
客户机-服务器是互联网的分布式模型，但我不知道是否所有的客户机服务器都是分布式的(例如，什么是x服务器？)
我认为OSI模型是分布式计算中客户机-服务器模型的协议栈，但我不是积极的。
所有顺序都是异步的？
所有的分布式/并发/并行都是同步的？
有人能做一个Venn图，或者至少用集合来描述它们是如何相交的吗？我也希望有人愿意在解释中提供更多的深度。
编辑:我们也可以添加多线程和
浏览 4提问于2015-05-30得票数 2
2回答
从Java-8开始，我们可以使用并行流(java.util.stream包) 根据理论，众所周知，与Java的(顺序)流相比，Java的并行流适合于需要并行执行操作的情况。 此外，并行流在管理并行性时存在比特开销，因此需要更加小心。 可以使用它的实际用例有哪些？此外，在这样的实际用例中，它是如何智取并行的成本的？
浏览 37提问于2020-04-23得票数 0
2回答
我有以下代码(只是我为这个问题编写的一个示例)，它简单地计算了我以三种方式实现的范围的和：
串行
平行流
用ForkJoinPool
令人惊讶的是，串行方法是最快的。实际上，它占用了另外两个时间的%10。
为了使Java流更快，什么是正确的配置？我做错什么了？
package ned.main;
import java.util.Date;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ForkJoinPool;
import java.util.stream.Int
浏览 4提问于2017-03-30得票数 0
回答已采纳
我一直在写一篇关于ASP.NET MVC (http://visualstudiomagazine.com/articles/2013/07/23/async-actions-in-aspnet-mvc-4.aspx)中的异步控制器方法的文章，我想我可能忽略了这一点。
考虑一下我编写的这个方法，它非常类似于本文中的一个示例：
[HttpGet]
[AsyncTimeout(8000)]
[HandleError(ExceptionType = typeof(TimeoutException), View = "TimedOut")]
public async Task<A
浏览 0提问于2015-03-18得票数 12
回答已采纳
我正在张贴我的手机的当前位置，按下一个按钮到一个本地的网络服务器。The服务器正确地接收这些帖子。
但是，由于某种原因，我只能向服务器发送一个位置，然后只调用一次。编辑:异步任务被调用，但是doInBackground方法没有被调用.-然后每个后续的按钮都按下这个任务。我确实在上面的链接中读到过，它只能被调用一次，但我假设每个对象只能调用一次，而且由于某种原因，在我更改某些内容之前，它都运行得很好，而且都搞砸了。
我需要能够在几分钟内从电话中发送数百个这样的请求，所以这里的任何指导都是有用的。谢谢!
package com.spencer.gps;
import android.app.Ac
浏览 4提问于2013-12-28得票数 0
回答已采纳
我有一项任务，它需要很多秒才能完成。因此，我想知道是否使用Java中的多线程概念，是否可以使用多个线程来执行单个任务，以便我的任务能够快速完成。
这是我的例子。线程类：
public class ThreadImpl implements Runnable {
@Override
public void run() {
String value="a";
for (int i = 0; i < 2147483646; i++) {
value = value + "b";
浏览 2提问于2020-12-23得票数 1
回答已采纳
我在使用spring 1.2.7，我在parallelStream().forEach(o -> addAddtionalData(id))中尝试使用它时遇到了一个parallelStream().forEach(o -> addAddtionalData(id))，但是stream()很好，我认为这可能是一个线程问题，但是我不能很好地解释它，谁能帮我指导一下吗？
private void addAddtionalData(Long id){
// request is null but not the first time loop in parallel stream
浏览 3提问于2016-07-29得票数 1
回答已采纳
我想在Java 8中试用ForkJoinPool，所以我编写了一个小程序，用于搜索所有文件，这些文件的名称在给定目录中包含特定的关键字。
程序
public class DirectoryService {
public static void main(String[] args) {
FileSearchRecursiveTask task = new FileSearchRecursiveTask("./DIR");
ForkJoinPool pool = (ForkJoinPool) Executors.newWorkSteal
浏览 1提问于2018-08-02得票数 6
回答已采纳
1回答
推荐使用哪一种: 1.单个kafka流从多个主题中消费2.不同的kafka流从不同的主题中消费(我已经使用过它，没有遇到任何问题)
是否有可能达到#1？如果是的话，这意味着什么？如果我使用'EXACTLY_ONCE‘设置，它会带来什么样的复杂性？
kafka版本:2.2.0CP2
浏览 1提问于2020-06-18得票数 0
2回答
2015年更新-10-30
基于Roland Kuhn Awnser：
Akka流使用在Actors之间的异步消息传递来实现流处理阶段。在异步边界上传递数据有一个开销，您在这里看到:您的计算似乎只需要大约160 is (来自单线程测量)，而流解决方案每个元素大约需要1s，主要是消息传递。
另一个误解是说“流”意味着并行性:在您的代码中，所有计算都在单个Actor (映射阶段)中依次运行，因此不能期望在原始的单线程解决方案上有任何好处。
为了从Akka流提供的并行性中获益，您需要有多个处理阶段，每个处理阶段都执行
每个元素1 s，也见docs。
我做了些改变。我的代码现在看起来像是：
o
浏览 5提问于2015-10-29得票数 10
回答已采纳
我想知道，通常情况下，如果程序的一部分可以安全地并行化，从而获得显著的性能提升，我们应该这样做吗？还是我们需要考虑这项工作的重要性，因为它会影响可伸缩性。当你决定并行化的时候，你的思维过程是什么？
例如，在我的应用程序中，用户可以将图形数据结构提交到服务器端进行处理。每个节点可以独立地并行处理，并且是非阻塞的IO工作.用户平均提交3-4个节点，但可能高达100个.平均来说，一个节点需要大约1秒的时间来处理。这是一个高流量的领域，但性能并不重要，因为用户需要立即作出响应。
在这种情况下，并行化可以大大加快速度。但我担心的是，这是因为它的高流量和可能有许多节点，它可能会占用大量的资源，减缓其他地区
浏览 0提问于2019-12-11得票数 0
我正在阅读实践中的爪哇纳妾。现在我完成了9.1章。但是我没有在java上开发GUI应用程序。
引用书中的话：
为什么GUI是单线程的？
在过去，GUI应用程序是单线程的，GUI事件是从“主事件循环”处理的。现代GUI框架使用的模型仅略有不同:它们创建一个专门的事件分派线程(EDT)来处理GUI事件。
以前我不是开发人员，所以我不明白GUI应用程序中的“主事件循环”意味着什么。此外，谷歌也没有给出明确的解释。
您能展示这种遗留技术的示例吗？是否有用于生产和使用任务的队列？
浏览 0提问于2017-02-28得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
