1回答
我们可以在spark streaming中在foreachRDD中启动一个新线程吗？
apache-spark、spark-streaming
我想在foreachRDD中启动一个子线程。作业不断地从hdfs目录中读取，并且每100批，我想启动一个模型训练任务(我将在那时创建rdds的快照并开始训练任务。训练任务需要很长的时间(2小时)，我不希望训练任务影响读取新的一批数据。
启动一个新的子线程是一个好的解决方案吗？子线程可以在主<em
浏览 1提问于2015-05-11得票数 1
1回答
捕获ConstraintViolationException并处理unque约束
mysql、hibernate、transactions、pessimistic-locking
我有一个数据库表(mysql)，其中包含父子关系，使我可以构建类别树。我有多个线程可以尝试获取，如果没有，可以在大致相同的时间创建类别路径(暗示了几个父子行)。问题是我只使用了TRANSACTION_READ_COMMITTED，因此可能会出现竞争条件，线程可以为类别子路径创建父子路径，因为它找不到它，然后(lo!)另一个线程在同一时间做了这件事。为了解决这个问题
浏览 26提问于2011-03-06得票数 2
回答已采纳
1回答
是否可以在c++中新创建的线程中加入子线程？
c++、multithreading、join、boost
大小写如下:我有一个主进程，让我们使用pid=1假设，主进程创建具有相同pid和不同线程ids的子线程。我想在不阻塞主线程的情况下加入子线程，所以我从主进程创建了一个新线程，并试图在那里加入子线程，但没有成功。我想知道，是否可以在新创建的线程中加入子
浏览 0提问于2014-09-25得票数 2
回答已采纳
5回答
将线程优先级传递给线程池
java、multithreading
我有一个Java组件，它执行一些超级复杂的业务逻辑，其中一些被并行化，执行子任务的线程被池化。现在，对该组件的每个请求都可以具有某种优先级，该优先级以某种方式映射到线程优先级。在开始执行时，我可以为执行线程分配一个适当的优先级。有问题的部分是将优先级传递给每个执行子任务的线程。我知道生成一个新的</em
浏览 2提问于2010-12-30得票数 5
1回答
R中有没有一个子集函数，可以让我平衡子集和条件？
r、subset
我正在处理一个大型数据集，它需要子集才能同时在多个线程上运行。为了做到这一点，我需要将它分成N个子集，希望这些子集的大小大致相同。但是，我在表中有一个类别变量，我需要确保具有相同类别的所有内容都在相同的子集内。有些类别只有2行，但有些类别最多可以有2,000行。更高的优先级是，任何类别都不会超过一个子集，所以如果我有一个包含5000行的数据集，其中3000行<em
浏览 9提问于2021-01-30得票数 0
回答已采纳
2回答
CUDA中的棋盘索引
indexing、cuda
我想在CUDA中做一个计算，我有一个很大的一维数组(代表一个格子)，我把它划分成长度为#part的子数组，我想让每个线程在每个子数组上做几次计算。更具体地说，假设我们有许多线程，#线程，以及许多块，#块。该数组的大小为N=2*#部分*#线程*#块。如果我们从1到2*#blocks*#threads对子数组进行编号，我们希望首先使用#threads*#blocks线程对偶数组的<em
浏览 1提问于2012-04-17得票数 1
回答已采纳
2回答
回收线程以提高C#中递归调用的并行性
c#、multithreading、recursion
我在C#中有一个任务，需要递归地计算树状结构中的项的属性。基本上，我只是进行递归深度优先搜索，但使用线程来并行化进程。我只是在考虑这样的场景:一个或多个原始线程具有相对较长的运行时间，足以让其他根子线程(及其后代)有时间在该线程或那些线程完成之前完成处理。这意味着我将拥有潜在的可工作线程，而不做任何工作。我想要
浏览 1提问于2015-02-07得票数 2
2回答
具有多GUI线程的mdi应用程序
c#、multithreading
为MDI中的每个子C#提供单独的GUI线程的MDI应用程序可以吗？在visual中，默认的winform应用程序具有STA (单线程单元
浏览 10提问于2008-10-21得票数 3
1回答
在春季启动多个线程时保留线程本地bean
java、multithreading、spring
hashMap中)，这样只要注入bean，我就可以从代码路径中的任何其他类中轻松地访问这些细节。但是，一旦我尝试做一些聪明的事情(在一个单独的线程中启动一些任务，以模拟类似于“失火和遗忘”的调用)，我注意到，无论代码路径(在这个新线程中)依赖于线程本地bean，我都会被烧毁，因为以前hashMap这对我来说是非常有意义的，因为毕竟，一旦我启动了一个新线程，它就不会
浏览 4提问于2014-07-25得票数 0
2回答
ForkJoinPool似乎浪费了一个线程
java、java-7、fork-join
因此，我有一个从RecursiveAction继承的对象，它被提交到池中。在该类的计算方法中，我对来自不同类的对象集合调用invokeAll，这些对象也继承自RecursiveAction。为了测试目的，我只在第一次提交一次对象.我天真地期望看到所有四个线程都在忙什么，因为调用invokeAll的线程将为自己抓取一个子任务，而不只是坐以待毙。我可以想出一些原因，为什么它可能不能这样工作。
在
浏览 1提问于2012-03-13得票数 7
回答已采纳
1回答
是Apache中的一个任务单线程
multithreading、parallel-processing、apache-flink、flink-streaming
我是Flink的新手。据我理解，在Flink中，TaskManager可以被划分为多个槽，一个时隙可以分配多个任务，一个任务是一个线程。让我们看看WordCount示例：据我理解，一个任务完全是一个线程，有三个任务：Source + map()、keyBy()/window()/apply()和Sink。因此，每个线程都有自己的线程，这意味着在这个示例中我们需要三个线程。我们可
浏览 2提问于2020-05-15得票数 4
回答已采纳
1回答
在典型的Intel/AMD多核机器上快速计算/大内存的多线程效率
multithreading、performance、intel、cpu-architecture、amd-processor
对于使用多线程进行密集计算的开发人员来说，这是一个有点实际的问题。根据处理器的<
浏览 3提问于2021-04-01得票数 0
1回答
进程和线程之间的通信
operating-system、ipc
我知道有几种方法可以实现IPC。如管道、插座等。假设我们有一个父进程A和两个子进程B和C。Q1:在这种情况下，IPC方法是有限的吗？要实现这种IPC，是否只能使用某些类型的IPC？比如它只能使用管道，共享内存而只能使用信号。
Q2:如果子进程想与其父进程通信，是否需要IPC？(如果D想与A通信，需要IPC吗？)Q3:如果B中有一个线程，D中有一个<e
浏览 0提问于2014-03-19得票数 0
回答已采纳
2回答
在多个EAGLContexts之间切换成本？
ios、opengl-es、opengl-es-3.0、eaglcontext
我正在编写一些具有网格视图的代码(一次在屏幕上显示20个子视图)。每个子视图都用GL绘制其内容，并有自己的绘图线程和EAGLContext。这样做的好处是，每个视图都相对独立于应用程序中其他GL的使用，尽管屏幕上有20个这样的视图，但我们必须使用glFlush+setCurrentContext:每帧20次。我的直觉告诉我，这不是GL最有效的使用。
我的<
浏览 0提问于2014-04-26得票数 3
1回答
如何在具有多个兼容所有者的Python中锁定资源
python、multithreading、concurrency、thread-safety、locking
我有一个具有共享资源的多线程应用程序。有两种类型的线程可以访问这个共享资源：A和B。只要没有其他类的线程也访问资源，相同类型的任意数量的线程就可以同时访问该资源，而不存在竞争条件。目前，我有一个保护共享资源的普通锁，以避免不兼容的线程函数同时访问资源时可能出现的竞争情况。但是
浏览 15提问于2020-06-08得票数 0
回答已采纳
3回答
STL向量和线程安全
c++、multithreading、stl、vector、thread-safety
假设我有一个由N个元素组成的向量，但是这个向量中最多有n个元素具有有意义的数据。更新后，线程调用多个子线程来读取最多第n个数据并执行一些计算。
可以保证，子线程永远不会更改或删除数据(事实上，无论如何都不会删除任何数据)，并且更新程序在完成更新后会立即调用子线程。到目前为止还没有发生问题，但我想问一下，如果上一次更新留下了一些子工作线程，那么<e
浏览 7提问于2010-12-03得票数 12
回答已采纳
1回答
KeyBy没有为不同的键创建不同的键流。
apache-flink、flink-streaming
我正在读取一个简单的JSON字符串作为输入，并根据两个字段A和B键输入流。但是，KeyBy为不同的B值生成相同的键流，但用于A和B的特定组合。投入： "A": "352580084349898", "C": "A"这是我的Flink代码的核心逻辑：
DataStream<这是字段B的<
浏览 0提问于2019-01-29得票数 0
回答已采纳
5回答
如果启动要求没有得到满足，什么是终止程序的良好做法？
java、exit
我的应用程序中有一个初始化线程，它聚合并依次运行几个子线程(检查必要的目录，检查xml文件是否可用，等等)。如果不满足要求，我希望我的程序安全终止。
我的另一个想法是，每个线程
浏览 1提问于2013-09-04得票数 0
回答已采纳
2回答
Java中的线程和事件处理
java、android、multithreading、event-handling
我有几个问题，以帮助理解正确的方式做事件处理在我的应用程序。
下面是我看到<e
浏览 4提问于2011-05-28得票数 1
回答已采纳
1回答
我向客户发送数据的设计是否正确？
multithreading、queue、producer-consumer
我提到这一点是为了防止有人提出在C++中实现时无法有效工作的解决方案。运行在线程t1上的生产者向运行在线程t2上的使用者插入图像。使用者有一个客户端列表，他应该将图像以不同的间隔发送给客户。例如，client1每1秒需要图像，client2每5秒需要图像，等等。在使用者中有一个主队列imagesQ，生产者将图像排入其中。除了主队列之外，使用者还管理大小为客户端数量的
浏览 1提问于2018-09-26得票数 0
云服务器
对象存储
ICP备案
云点播
腾讯会议
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号