在我的应用程序中，我有许多类可以使用Parallel.For语句计算它们的任务。每个Parallel.For都使用自己的ParallelOption来设置最大程度的并行性。
应用程序流依赖于用户设置，因此存在这样的情况:类A(并行计算)调用类B(也是并行计算)，或者调用类C(不使用任何并行计算)。
另一种模式是递归调用，在每个递归级别上都进行并行计算。
我的问题：
是否有可能设置一个全局线程池，所有类都使用该线程池来执行其计算，并且线程的数值为应用程序被全局控制？
是否有可能将线程池与Parallel.For结合起来，从而使大多数现有代码保持不变？
与独立的parallel.for调用相比，线
浏览 5提问于2016-11-11得票数 2
回答已采纳
1回答
我尝试了下面的应用程序，其中两个客户端连续发送一条信息，另一个接收他们。但是在这里，messageArrived方法似乎是在一个线程中调用的。因为一旦一个客户端的消息被卡住，其他客户端的消息也不会被接收到。这是我的实现问题，还是这种行为？请指点。下面显示的是我的代码。
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;
import java.util.Timer;
import java.util.TimerTask;
import org.eclipse.paho.cli
浏览 1提问于2016-01-19得票数 1
回答已采纳
我在我们的应用程序中有几个泄漏的ThreadPools。这些泄漏的threadPools没有任何特定的名称，并使用java的默认命名约定。我们的应用程序启动的所有ThreadPools都有特定于应用程序的名称。看起来有一些依赖库正在启动这些threadPools。我能够重现这段代码，但我需要帮助才能找到启动这些threadPools的代码。任何帮助都是非常感谢的。应用程序stackDump泄漏的ThreadPool的堆栈转储。所有线程都处于相同的状态。
"pool-11-thread-1" #23 prio=5 os_prio=0 tid=0x00007f9f0c179000
浏览 3提问于2017-03-08得票数 0
2回答
我有一个带有Hibernate和Hikari DataSource的Spring项目。如果我对注入的SessionFactory对象具有一些获得会话对象的功能，那么在几天内，对于任何与db操作类似的方法，我都会有这样的异常(只有重新启动才能解决这个问题)：
org.springframework.transaction.CannotCreateTransactionException:
Could not open JPA EntityManager for transaction; nested exception is
javax.persistence.PersistenceExce
浏览 3提问于2017-06-07得票数 31
3回答
考虑Netty教程中的示例(尽管这不是我见过的唯一示例)：
Executor bossPool = Executors.newCachedThreadPool();
Executor workerPool = Executors.newCachedThreadPool();
ChannelFactory channelFactory = new NioClientSocketChannelFactory(bossPool, workerPool);
这里创建了两个单独的缓存线程池。但是为什么呢？如果多线程池的大小是固定的，我可以理解它们的用途，但缓存的线程池不是这样。那么，如果只需要一个不断扩
浏览 1提问于2013-04-18得票数 5
1回答
我想有一个系统托盘图标，只有当我需要显示气球提示，然后隐藏图标时，气球提示关闭。
但是，一旦显示了图标，我就无法让它消失，因为事件处理程序没有被触发：
public partial class MainWindow : Window {
public static NotifyIcon trayIcon = new NotifyIcon();
public MainWindow() {
InitializeTrayIcon();
}
void InitializeTrayIcon() {
trayIcon.Text = &#
浏览 0提问于2016-07-26得票数 0
回答已采纳
1回答
我配置了1个线程池@异步(value=“pool_1”)。现在我想在不同的类中使用这个线程池，所以我将@异步(value=“pool_1”)放在了我的两个不同的类之上。我只想得到确认，好像它不会创建两个独立的线程池。就像我已经将我的池大小设置为500个线程，在两个不同的类上放置相同的异步，难道不会将池大小设置为1000，对吗？另外，这些线程将是共享的，而不是在两个类之间划分的(右)
浏览 3提问于2021-10-06得票数 1
回答已采纳
1回答
我有一个关于mod_passenger和单例类(rails 2.3.5和Ruby1.9.1)的问题。
在我的应用程序中，我有一个实现线程池(线程安全)的Singleton类。
还有一个控制器来管理所有的线程(终止和启动它们)。这个控制器使用前面的单例类在线程上执行操作。
在本地，使用config.cache_classes = true的WEBrick可以正常工作。在生产环境中，使用mod_passenger (也是config.cache_classes = true)不起作用:线程不会被杀死。但是，如果我从控制台(生产环境)使用singleton类，它可以正常工作。
可能是mod_pass
浏览 1提问于2010-02-18得票数 1
回答已采纳
我在viewdidload方法中的单独线程中调用了一个方法
[NSThread detachNewThreadSelector:@selector(callWebService) toTarget:self withObject:nil];
-(void)callWebService{
NSAutoreleasePool *pool = [[NSAutoreleasePool alloc] init];
[NSThread detachNewThreadSelector:@selector(loadImages) toTarget:self withObject:nil];
[p
浏览 4提问于2010-12-06得票数 2
我想知道，当所有线程都在使用时，FixedThreadPool或ScheduledThreadPool中是否有增加线程数量的方法。对于Example1:假设我们使用一个大小为5的线程，当所有线程都在使用时，另一个需要执行的任务或函数必须等待线程释放。我需要避免这种情况，并且在不使用CachedThreadPool.的情况下，线程的数量必须动态增加，这样做有什么办法吗？
Example2:
ScheduledExecutorService execService = Executors.newScheduledThreadPool(1);
在上面的示例2中，我已经将线程的数量限制为1。现在，当
浏览 2提问于2017-02-21得票数 1
回答已采纳
1回答
我用Parallel.ForEach编写了一个使用所有可用内核的程序。ForEach的列表包含~1000个对象，每个对象的计算需要一些时间(~10秒)。在这个场景中，我设置了一个这样的计时器：
timer = new System.Timers.Timer();
timer.Elapsed += TimerHandler;
timer.Interval = 15000;
timer.Enabled = true;
private void TimerHandler(object source, ElapsedEventArgs e)
{
Console.WriteLine(D
浏览 8提问于2015-09-18得票数 11
我有一个使用2个长时间运行的SwingWorker任务的应用程序，并且我刚刚遇到了几台安装了更新的JVM的Windows计算机，它们只启动了其中的一个。没有显示错误，所以我必须假设缺省线程池只有一个线程，因此当我尝试执行第二个SwingWorker对象时，它会被排队。
那么，(1)如何检查默认SwingWorker线程池中有多少线程可用，以及(2)如果需要更多线程，如何添加线程？
还有什么我应该知道的吗？这种明显的单线程线程池情况违背了我所有的期望。
我正在设置一个ThreadPoolExecutor，但这似乎太错误了.
浏览 1提问于2010-05-04得票数 4
根据下面的代码，
Process Proc=null;
ProcessStartInfo DirectX=new ProcessStartInfo("dxsetup.exe", "/silent");
DirectX.WorkingDirectory="Tools\\directx";
Proc=Process.Start(DirectX);
在进程结束时，我将在Visual的输出窗口中获得The thread '<No Name>' (0x1eec) has exited with code 0 (0x0).。
我希
浏览 5提问于2013-10-18得票数 0
回答已采纳
2回答
新线程()和线程池？
、、、
为什么线程(我将IsBackgroundthread设置为True__)不使用线程池线程运行？
/*1*/ volatile bool r = false;
/*2*/ var g= new Thread(() => r=Thread.CurrentThread.IsThreadPoolThread );
/*3*/ g.IsBackground = true;
/*4*/ g.Start();
/*5*/ g.Join();
/*6*/ Console.WriteLine(r); //false
而这段代码(显然)是在线程池线程上运行的？
Task.Facto
浏览 1提问于2013-06-27得票数 1
回答已采纳
什么是数据库的“连接限制”，如下所示：
如果我有一个查询数据库的ruby应用程序，同时发出100个请求，那么数据库连接限制是如何发挥作用的呢？
有80个请求被拒绝吗？排队？
每个查询是一个单独的连接，还是多个查询由单个连接处理？
我正在使用ActiveRecord。提前感谢！
浏览 0提问于2014-04-16得票数 2
回答已采纳
VS2010线程窗口显示25个线程和进程.Threads.Count.50
其他25个人在做什么？
浏览 0提问于2010-06-18得票数 1
回答已采纳
1回答
MQTT (莫斯科)连接池？
、、、、
您对Java中的Mosquitto连接池有什么建议？我们在建立每个连接上浪费了太多的时间，所以我们认为某种形式的重用会更好。
浏览 1提问于2015-08-20得票数 0
回答已采纳
对不起，我是一个新的可可编程新手，我不确定我是否真正了解nsautoreleasepool是如何工作的。
我读到的任何地方都说NSAutoreleasePool对所有的自动释放调用负责(谈论的是最后声明的NSAutoreleasePool )。
考虑以下代码：
int main(int argc, char *argv[]) {
//NSAutoreleasePool * pool = [[NSAutoreleasePool alloc] init];
int retVal = UIApplicationMain(argc, argv, nil, nil);
//[p
浏览 4提问于2012-01-10得票数 3
回答已采纳
我正在查看Java 8固定线程池的代码。下面是一个小示例：
ExecutorService service = Executors.newFixedThreadPool(100);
try {
for (int i = 0; i < 10; ++i) {
service.submit(() -> "In another thread!");
}
} catch (Exception e) {
// Do nothing
} finally {
浏览 0提问于2017-03-01得票数 1
我想和你分享我的想法。
考虑一下，您必须自己实现线程池。
我想有一些成员字段，比如线程的private static List<Thread>，可以作为我的“池”。
我还有两种方法：
从池中分配线程。
将线程返回到池中。
我的问题是
如何保护List不同时被某些线程访问：
我想用synchronize声明这两种方法，然后才意识到这不太好，因为我不能这样做：
将线程返回到池中，同时从池中取出线程。
我还想过使用一个线程安全的集合，比如向量，但似乎也有同样的问题。
2.您认为线程池类应该是Singleton吗？您认为代码的哪一部分应该负责分配它的单个实例？
浏览 1提问于2013-01-28得票数 0
1回答
考虑一项守则：
@Autowired
private AsyncRestOperations restTemplate;
@RequestMapping("/abcd")
public CompletableFuture<Result> process(HttpRequest request) {
convertListenableFutureToCompletableFuture(restTemplate.getForEntity("http://...", Result.class))
.thenApply(/*Some
浏览 2提问于2015-09-24得票数 1
回答已采纳
我想写一个多线程合并排序使用线程池，因此下载了boost库。我是c++的新手，很难理解如何运行源代码中给出的示例程序。这是我下载的源码.. ...它在下载section...Any帮助是赞赏的。
浏览 1提问于2010-12-08得票数 1
2回答
几个单身汉:每个任务一个
、、、、
我有一个C++多线程应用程序，它在单独的线程中运行任务。每个任务都有一个对象来处理和存储它的输出。每个任务创建不同的业务逻辑对象，并可能创建另一个线程或线程池。
我想要做的是为由任务运行的任何业务逻辑对象提供一种简单的方法，以访问每个任务的输出，而无需将“输出”对象手动传递给每个业务逻辑对象。
我看到的是创建输出单例工厂并将task_id存储在TLS中。但问题是，当业务逻辑创建新线程或线程池时，这些线程在TLS中将不具有task_id。通过这种方式，我需要访问父线程TLS。
另一种方法是简单地抓取任务开始后的所有输出。在那个时候会有不同任务的输出，但至少，总比没有好.
我正在寻找任何的建议或想
浏览 3提问于2012-12-06得票数 2
回答已采纳
1回答
所以我有我的Android蓝牙应用程序，它有它的主机和客户端。问题是，因为我要建立多个连接，所以我需要一个线程来处理每个连接。这些都是牛奶饼干，所以我想我应该把所有的线程放在一个数组中。一些研究表明，更好的方法是使用线程池，但我似乎无法理解它是如何工作的。另外，在数组中保存线程实际上是可能的吗？
浏览 0提问于2012-03-15得票数 2
回答已采纳
是否可以为整个程序创建一个线程池，以便重用线程，还是需要将ExecutorService全局/传递给使用它的所有对象。
更确切地说，我有多个任务在我的程序中运行，但它们不经常运行。
ScheduledExecutorService executorService = Executors.newScheduledThreadPool(1);
我认为没有必要让一个完整的线程一直运行于每一个任务中，但是每次执行任务时重新启动线程也会花费很大的代价。
是否有更好的选择使线程池全球化？
浏览 0提问于2013-08-14得票数 3
回答已采纳
在没有Java执行器的情况下，必须为每个可运行的任务创建新的线程。创建新线程需要线程开销(创建和销毁)，这会增加非执行器程序的复杂性和浪费时间。
参考代码：
没有Java执行器-
new Thread (aRunnableObject).start ();
使用Java Executor -
Executor executor = some Executor factory method;
exector.execute (aRunnable);
归根结底，执行者抽象了如何管理线程的低层细节。
这是真的吗？
谢谢。
浏览 0提问于2010-08-11得票数 3
回答已采纳
2回答
Java线程数量随时间增长的原因
、、、、
我有一个独立的Java控制台程序，它在生产中使用大约80-170个线程(160是一个典型的平均负载数)线程。一些代码在项目中被替换，这在功能上是很好的，但是线程数在启动程序之后会不断增加。当虚拟机几乎崩溃时，我就意识到了这个问题。然后它有30.000根线。
我想在生产环境中找到这种行为的原因，所以如果有任何有用的工具，它必须是一个命令行程序，或者应该能够从远程主机上运行。
我使用'ps huH p\ wc -l‘命令和VisualVm program.Unfortunately VisualVm远程检查它，只提供有关线程号的信息，" thread“选项卡不活动。
我试图从j堆栈
浏览 1提问于2018-08-17得票数 2
回答已采纳
我正在编写的程序要求用户提供无限数量的项目，我的程序将对这些项目中的每一项执行一些操作。我让我的程序在3个线程上做这件事，所以它会更快地完成。使用我现在的程序，它继续循环检查每个线程是否还在运行，如果3个线程中有1个没有运行，它会创建一个新的线程。我创建一个新线程的唯一原因是它告诉我一个线程只能使用一次。有没有更好的方法来做这件事？
浏览 1提问于2016-02-29得票数 0
1回答
在开始的时候...异步调用时，我传递的委托将在默认线程池中处理(根据文档)。
例如: System.IO.Stream.BeginRead( byte[] buffer，int offset，int count，AsyncCallback callback，object state)；
我怎样才能使用专用的线程池来处理异步方法呢？
(我知道这是可以做到的，因为CCR (并发协调运行时)也在这样做(根据他们的文档))
浏览 0提问于2010-02-01得票数 2
回答已采纳
1回答
我有一个C++程序，它尝试并行处理数组的每一行，在一行完成后，它继续处理下一行。我当前的程序为数组的每一行创建一个线程，并在使用后连接它们。但是看起来程序在创建/关闭线程上浪费了很多时间。
有没有办法只创建一次线程，并为每一行等待最慢的线程完成，然后执行下一行的函数？
下面是我的示例代码：
#include <iostream>
#include <thread>
using namespace std;
#define THREAD 5
int arr[2][10000];
void update_arr(int i, int j_s, int j_to){
浏览 0提问于2018-09-19得票数 2
我是Quartz .NET的新手，我使用的是2.6版本。我有两种工作，低优先级和高优先级。我只想要一个线程池来处理高优先级的工作。是否有一种方法来配置调度程序来处理这个问题？
谢谢
浏览 0提问于2018-04-11得票数 0
回答已采纳
1回答
我在我的linux实例上看到了cassandra进程，它使用了大约38 of的内存，并在它下面显示了大约700个线程。
当通过python或java连接到数据库时？它们是成为主java进程下的线程还是单独的OS进程？
当集群连接产生多个线程时，它们是否也会成为主进程下的线程？如果是，如何区分连接线程和连接生成线程？
为会话线程分配的内存，它是否在非堆内存下分配？
更新- @chris -这是tpstats的输出
[username@hostname ~]$ nodetool tpstats
Pool Name Active
浏览 0提问于2019-02-08得票数 1
回答已采纳
2回答
我在做动画。我正在生成一堆图像，我想把它们添加到gif编码器中。由于添加过程可能需要相当长的时间，我希望在一个单独的线程中完成这一过程。我的想法是这样做：
public class MyThread implements Runnable {
private AnimatedGifEncoder encoder = new AnimatedGifEncoder();
public void run() {
encoder.start("MyFile.gif");
}
public void addFrame(Buffered
浏览 6提问于2015-12-03得票数 0
回答已采纳
1回答
来自 API：
当不指定线程池而创建AsynchronousFileChannel时，通道与系统相关的默认线程池相关联，该线程池可能与其他通道共享。
我还没有在其他地方见过这个术语，也没有通过网络搜索找到任何具体的解释。系统相关的默认线程池到底是什么？它的特点是什么？它们在不同的系统之间会有什么不同呢？
浏览 1提问于2015-08-06得票数 9
回答已采纳
1回答
有人用滑雪板课的"n_jobs“吗？我是在Anaconda3.464位学习滑雪。Spyder版本为2.3.8。我的脚本不能完成它的执行后，设置"n_jobs“参数的一些滑雪类为非零value.Why，这发生了吗？
浏览 0提问于2016-07-12得票数 4
1回答
我有一个接收消息并将它们发送到实例的服务，我收到的每条消息都会发送到新的任务，所以处理消息的操作将是异步的
public void ReceiveMessage(string Message) {
Logger.Logger.Log($"Receive Message {Message} in METHOD method");
//see in the log time stamp 12:13:51.000
Task.Factory.StartNew(() =>
{
浏览 35提问于2018-05-31得票数 0
关于AsyncTasks在Honeycomb+上的执行顺序的问题。每
当第一次引入时，AsyncTasks是在单个后台线程上串行执行的。从甜甜圈开始，这被更改为一个线程池，允许多个任务并行操作。从蜂窝开始，任务在单个线程上执行，以避免由并行执行引起的常见应用程序错误。
我的问题是，在后台串行执行的AsyncTasks也会在同一个线程上运行吗？
例如，正在执行任务A、B和C的会在线程1上运行任务A，然后在线程1上运行任务B，然后在线程1上运行任务C吗？
或者，AsyncTask.SERIAL_EXECUTOR会在线程1上执行任务A，然后在线程2上执行任务B，然后在线程3上执行任务C？在此
浏览 0提问于2016-01-20得票数 0
回答已采纳
3回答
我正在从UI事件(分离类)启动一个工作线程(在一个新类中编写)。现在，当从主UI线程创建新的辅助线程时，它将立即从控件返回，从而导致worker线程类对象被销毁。通过检查下面的代码可以找到更好的解释。
//class - UI
void CUIClass::button_click()
{
CDataProcess obj;
obj.Start();
}
//class - DataProcess
CDataProcess::CDataProcess()
{
}
CDataProcess::~CDataProcess()
{
}
void CDataProcess::Star
浏览 2提问于2015-04-21得票数 1
什么是java.I中的运行时常量池和方法区域。我读到JVM创建了这两者，但是哪一个最先出现？还有它们包含的内容？任何帮助都将不胜感激。
浏览 1提问于2014-04-08得票数 10
回答已采纳
3回答
我们有一个桌面应用程序，它有一些后台线程，并且由于执行外部命令，还需要线程来处理out和err流。
我们既可以创建新线程并让它们完成，也可以重用线程。重用线程是否有一些好处，例如在性能或内存使用方面？
浏览 6提问于2014-06-23得票数 4
回答已采纳
在Java中，我得到了一个强制转换异常：
java.lang.ClassCastException: java.util.concurrent.ThreadPoolExecutor$Worker
incompatible with com.myco.TaskListEntry
at com.myco.JobThreadFactory.newThread(JobThreadFactory.java:17)
代码如下：
public class JobThreadFactory implements ThreadFactory {
@Override
public Thread n
浏览 1提问于2013-02-28得票数 1
回答已采纳
我有一个执行某些功能的fortran atoms.out文件。我在python中使用以下命令调用该fortran文件：
values = subprocess.Popen(["./atoms.out", "./%s.klj" % test1, "./%s.out" % test1], stdout = subprocess.PIPE)
我看过，但我不认为它是我想要的，因为它使用n个CPU来处理单个作业。
fortran文件执行的计算不是独立的，不能与python pp一起使用
因此，我的问题是如何向多个不同的CPU提交多个作业，例如，我有:7个文
浏览 0提问于2012-09-10得票数 0
回答已采纳
1回答
我正在做一个项目，其中我需要插入数据到Cassandra数据库。因此，我使用Pelops client。
我有一个多线程的代码，将插入到卡桑德拉数据库使用Pelops client。我使用ExecutorService来实现这一点。
在我的程序中，每个线程都会在某个范围内工作，比如
Thread1 will work on 1 to 20
Thread2 will work on 21 to 40
...
...
下面是我用来插入Cassandra数据库的代码-
private static int noOfThreads = 5;
private static int noOfTasks =
浏览 0提问于2013-04-09得票数 2
回答已采纳
#import <UIKit/UIKit.h>
int main(int argc, char *argv[]) {
NSAutoreleasePool * pool = [[NSAutoreleasePool alloc] init];
int retVal = UIApplicationMain(argc, argv, nil, nil);
[pool release];
return retVal;
}
main方法在应用程序退出后调用池上的release，这会顺便将release发送到池中的所有对象。但是，由于在应用程序中创建的自动释放对象
浏览 0提问于2011-02-10得票数 9
回答已采纳
我是java中的一个机器人创建者，我很长时间都在使用单独的线程；对我来说，它非常重要的多线程构建应用程序。昨天我读了一些关于线程池和线程组的文章，但是我不知道哪一个更好。所以我想读一些关于这些问题的口语化的观点，例如使用，效率，容易实现等等。
任何意见对我来说都很重要，感谢每一个回复我的人。
I use this online to open the post. I dont have any code.
浏览 3提问于2015-07-31得票数 0
就像下面的代码片段一样，它在这个方法中使用@autoreleasepool块。
+ (UIImage *)decodedImageWithImage:(UIImage *)image {
// while downloading huge amount of images
// autorelease the bitmap context
// and all vars to help system to free memory
// when there are memory warning.
// on iOS7, do not forget to
浏览 1提问于2018-03-12得票数 0
回答已采纳
2回答
我有一个包含大量文本文件的文件夹列表。在这些文件中有链接。
使用这些链接中的每一个，我将需要获取一个网页，解析它，并根据那里的内容-将一个JPG文件保存到与包含提供链接的文本文件的文件夹名称对应的文件夹中。
现在的问题是，里面有很多文本文件和更多的链接。我在想，多线程连接和解析网页的过程可能不是一个坏主意。
所以我会有这样的东西：
directories.each do |directory|
...
all_files_in_directory.each do |file|
...
all_urls_in_file do |url|
# check if the
浏览 3提问于2012-04-20得票数 1
回答已采纳
1回答
我试着用Java学习多线程.我们使用两种方法创建线程，第一种方法是扩展thread类，第二种方法是通过实现Runnable接口。
在下面的示例中，我通过实现Runnable接口创建了一个线程。
class ThreadExample implements Runnable {
@Override
public void run() {
System.out.println("run method is called by thread named " + Thread.currentThread().getName());
S
浏览 3提问于2021-09-04得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
