1回答
我有一个更大的程序，我可以概括如下：
SequentialPart
ThreadPoolParallelized
SequentialPart
ParallelPartInQuestion
SequentialPart
此代码多次按顺序调用。
我使用人造丝线程并行第二部分，如下所示：
final_results = (0..num_txns).into_par_iter()
.filter_map(|idx| {
if !matches!(ret, None) {
浏览 11提问于2022-09-27得票数 1
1回答
线程安全客户端
、、
我正在使用，据我所见-当客户端连接到redis服务器时，有一个连接池。我不知道如何查询redis服务器，并确保它是以线程安全的方式进行的。
目前我这样做：
我正在创建全局指针client：client *goredis.Redis，然后执行以下操作：
go func () {
http.HandleFunc("/send_data/", trackHandler)
http.HandleFunc("/init/", initHandler)
http.ListenAndServe(":8000", nil)
} ()
所以
浏览 3提问于2014-07-03得票数 4
这个问题的目的是找到ThreadPool配置的正确选择，将其与单例模式(即服务层)中的Java7s CompletableFuture一起使用，以进行x次并发调用。
简单介绍一下java应用程序结构。
基于Java的WebServices，使用Spring的依赖注入、C3P0连接池，使用泽西提供的一系列API
由于状态、启用事务的prototype/request服务层、Hibernate DAO层(我们已经大量使用了标准)，控制器都是的作用域。
有超过100 (100)个api，然后有这1个只读聚合器api，它结合了其他10个只读api的结果。api具有以下结构
@Contr
浏览 2提问于2017-12-02得票数 0
2回答
我可以在java中创建一个新的线程池，并使用和方法在其上执行任务。
是否有一个‘默认’线程池，我可以重用在我的java程序中的所有执行器服务？还是我只需要创建一个包含默认线程池的单例？C#有一个默认线程池，在调用方法时运行任务。
浏览 6提问于2015-11-23得票数 12
回答已采纳
是否可以为整个程序创建一个线程池，以便重用线程，还是需要将ExecutorService全局/传递给使用它的所有对象。
更确切地说，我有多个任务在我的程序中运行，但它们不经常运行。
ScheduledExecutorService executorService = Executors.newScheduledThreadPool(1);
我认为没有必要让一个完整的线程一直运行于每一个任务中，但是每次执行任务时重新启动线程也会花费很大的代价。
是否有更好的选择使线程池全球化？
浏览 0提问于2013-08-14得票数 3
回答已采纳
Appengine - 1.9.63
GWT - 2.8.1
客户端到服务器端调用:使用标准GWT RPC实现
服务器端代码：
IndexSpec indexSpec = IndexSpec.newBuilder().setName("index").build();
Index index = SearchServiceFactory.getSearchService().getIndex(indexSpec);
Document doc = Document.newBuilder()...
try{
index.put(doc); //Line that resu
浏览 2提问于2018-04-29得票数 0
2回答
显式地调用“可细分的任务也不应该执行阻塞I/O”。它的主要目标是“计算任务计算纯函数或操作纯孤立的对象”。我的问题是:-
为什么设计ForkJoinTask来限制阻塞IO任务？
如果我确实实现了阻塞IO任务，那么问题是什么？
为什么spring和框架都是使用叉-连接执行器进行DB调用的示例呢？
在我的场景中，一个请求执行两种类型的工作，一种是加密，在200 ms内将CPU核心推入100%，第二，很少有数据库调用。任何类型的静态分区，如用于加密的6个线程和用于阻塞IO的2个线程，都无法提供CPU的最佳使用。因此，有一个叉-连接执行器，在总CPU数量上有一定程度的过度配置，再加
浏览 4提问于2015-02-26得票数 2
我目前正在Python3.7中使用asyncio，并使用asyncio.start_server()函数编写了一个TCP服务器。请参阅此示例：
也可以尝试使用“I/O完成端口”(IOCP)的asyncio.ProactorEventLoop
根据微软官方文档，它提到使用I/O完成端口和预先分配的线程池，但我找不到哪里可以分配线程的数量
我可以在哪里分配线程池中的线程数量？有谁能帮帮我吗？非常感谢!
浏览 2提问于2020-06-14得票数 0
2回答
如何使用ExecutorService，以便在应用程序级别为应用程序创建一个中心线程池，该应用程序的池大小将根据当时CPU可用的线程数来设置，然后应用程序的不同功能将根据它们的需要从这个中心池中使用线程。
浏览 3提问于2016-11-24得票数 3
回答已采纳
在我的应用程序中，我有许多类可以使用Parallel.For语句计算它们的任务。每个Parallel.For都使用自己的ParallelOption来设置最大程度的并行性。
应用程序流依赖于用户设置，因此存在这样的情况:类A(并行计算)调用类B(也是并行计算)，或者调用类C(不使用任何并行计算)。
另一种模式是递归调用，在每个递归级别上都进行并行计算。
我的问题：
是否有可能设置一个全局线程池，所有类都使用该线程池来执行其计算，并且线程的数值为应用程序被全局控制？
是否有可能将线程池与Parallel.For结合起来，从而使大多数现有代码保持不变？
与独立的parallel.for调用相比，线
浏览 5提问于2016-11-11得票数 2
回答已采纳
2回答
我们有一个有时间限制的应用程序，比如我们需要每500毫秒执行一次操作，这是一种监督，所以如果我们在500毫秒的坏事情发生之前不发出信息。
应用程序大量使用ThreadPool，这个看门狗与ThreadPool交互。
我们已经发现，在一些低端机器上，有时当我们排队等待一个新的工作项时，执行它需要大约800 so，所以看门狗就会开火。我们猜测，这与线程不足/创建新线程的ThreadPool有关。
是否有一种方法可以避免这种情况，比如强迫ThreadPool提前创建线程，或者在不同的线程中创建线程，从而使看门狗不必等到ThreadPool执行请求时才能执行？
浏览 2提问于2015-03-27得票数 0
回答已采纳
我正在使用。
在LazyFutureStream中，我想要持久化实体。
LazyFutureStream.parallel(1,2,3,4,5)
.map(id -> {
try {
SessionFactory sessionFactory = Application.getHibernateBundle()
.getSessionFactory();
ManagedS
浏览 0提问于2015-09-15得票数 1
1回答
我有一个程序，它可以一个一个地从站点列表中获取html文档，然后解析它。
ArrayList<String> links = new ArrayList<>();
for(String link : links) {
try {
Document doc = Jsoup.connect(link).get();
getInfo(doc);
}catch (IOException e) {
e.printStackTrace();
}
}
问题是，需要很长时间才能得到html文档，比如site1、s
浏览 2提问于2016-05-19得票数 4
回答已采纳
1回答
我需要创建一个连接池的数据库，可以重用的请求在瓶。文档(0.11.x)建议使用应用程序上下文g来存储数据库连接。
问题是在每个请求之前和之后创建和销毁应用程序上下文。因此，创建的连接数量没有限制，也没有连接被重用。我使用的代码是：
def get_some_connection():
if not hasattr(g, 'some_connection'):
logger.info('creating connection')
g.some_connection = SomeConnection()
return
浏览 3提问于2016-07-26得票数 3
1回答
我知道Akka调度程序与全球执行上下文之间的基本区别。
我用scala.concurrent.ExecutionContext.Implicits.global尝试了这段代码
import scala.concurrent.ExecutionContext.Implicits.global
val resultF = (0 to 100).map(
x =>
Future {
val startTime = System.currentTimeMillis()
val task = Future {
Thread
浏览 2提问于2017-09-11得票数 2
我正在构建一个小型多线程web服务器。QTcpSockets是在主线程中获取的，然后由QtConcurrent交给QThreadPool，QThreadPool最终处理数据并发送一个答案。
我的问题是，套接字是在主线程中创建并在另一个线程中处理的。当试图写入套接字时，这会导致错误：
socket->write(somedata);
QObject:不能为处于不同线程中的父线程创建子线程。(父线程为QNativeSocketEngine(0x608330)，父线程为QThread(0x600630)，当前线程为QThread(0x505f60) )。
干净的方法是将套接字对象移动到处理
浏览 1提问于2010-06-27得票数 7
回答已采纳
2回答
我正在用C语言编写一些apache (2.2)模块，而且我是个新手，所以我想知道：
我需要知道是否可以创建一个全局变量，该变量将在apache服务器开始运行时启动。
看，我需要有一个主机名的列表(这将是“特权的”)，这样我收到的每个请求，我需要检查主机名是否出现在列表中(以检查它是否“优先”)。
因此，该列表应该是全局的(这样每个服务器实例都将拥有该列表的相同实例)，并且我需要在开始时初始化它。
如果可能的话，我该怎么做呢？
谢谢!
浏览 0提问于2011-06-13得票数 5
回答已采纳
1回答
我使用静态ThreadLocal缓存一些重量级对象。考虑以下代码：
class MatchItemFinder
{
private static ThreadLocal<PaddedImage> tempImage;
MatchItemFinder()
{
if(tempImage==null)
tempImage = new ThreadLocal<PaddedImage>(
() => new PaddedImage(patchSize, patchSize));
浏览 2提问于2016-07-04得票数 0
回答已采纳
1回答
我可以在单个redis实例中创建的重展示数据库的数量是否有任何限制？
GRAPH.QUERY database1 "Cypher"
这些密钥的数量很高，是否存在性能问题？
谢谢
浏览 2提问于2019-12-31得票数 1
回答已采纳
我需要将大量文件(比如100 gbs )从一些共享的网络路径上传到数据库DBFS服务器。我正在使用下面的代码，它运行良好。但是我需要使用多线程概念来加速进程，无论是使用JSch和ExecutorService类线程池。
见我下面的代码
public static void sftpConnection()throws JSchException, SftpException, IOException {
System.out.println("Inside sftpConnection method");
JSch jsch = new JSch();
浏览 2提问于2014-09-05得票数 0
回答已采纳
3回答
有两个或多个线程: main和几个子线程。儿童是劳动者，主要控制着儿童的活力。一旦主线程检测到子线程死了，它就会创建新线程。
目前，我想不出比在循环中的每个线程上检查t.isAlive()更好的解决方案了，但是众所周知，开发人员应该不惜任何代价避免轮询。
请注意。工作线程可以在HTTP响应上等待几分钟(getInputStream()在URLConnection上)
更新
Worker没有完成其工作，但是在收到响应或超时时，它会创建新的连接，并再次等待服务器响应。
浏览 5提问于2015-04-06得票数 0
我刚刚注意到，.NET核心引入了Threadpool.QueueUserWorkItem的过载，它接受一个名为“首选本地”的布尔值，并允许我通过一个类型安全的状态对象(它有一个通用参数)。
目前是不完整的，看起来如下(对于后代-它可能在将来更新)：
QueueUserWorkItem<TState>(Action<TState>, TState, Boolean)
C#
public static bool QueueUserWorkItem<TState> (Action<TState> callBack, TState state, boo
浏览 0提问于2018-10-11得票数 4
回答已采纳
我使用的是一些第三方代码，在某些情况下可能会无限期挂起。这会导致挂起线程，这些线程会一直持有资源并阻塞线程池。
最终，线程池变得充满了无用的线程，系统实际上失败了。
在Java中，不能强制终止线程(kill -9)。但是，如何管理这种边缘情况呢？
浏览 2提问于2015-02-25得票数 0
我有一个ASP嵌入在一些VB6页面。DLL命中代码库数据库，这是一个过时的数据库引擎(上的方言/变体)，几乎没有人听说过它。初始化一个新的连接几乎需要一秒钟的时间，这是不可接受的慢，所以我创建了一个连接池，由一个VB类管理。该类的单个实例是在VB模块开始时创建的，即：
Private m_codebaseManager As New CodebaseManager
我的理解是，非类模块中的数据在DLL的生命周期中持续存在。这是正确的吗?如果不是，在什么情况下模块会“重启”？
浏览 0提问于2009-12-21得票数 0
请解释一下，为什么在ScheduledThreadPoolExecutor中javadoc是这样的：
此外，将corePoolSize设置为零或使用allowCoreThreadTimeOut几乎从来都不是一个好主意，因为一旦线程符合运行条件，可能会使池没有线程来处理任务。
当必须执行新任务时，我尝试分析如何在这个线程池中创建新线程，我认为javadoc中描述的问题不应该发生。
浏览 1提问于2018-01-24得票数 2
回答已采纳
1回答
我在一个Asp.Net网站上工作。目前，我正在创建(并关闭)每个页面的db连接(在加载中)。但我不确定，这才是真正的办法。我想知道，如果我在静态类或WebApplication的主Global.asax中创建一个db连接，它会比每页创建db连接更好吗？
顺便说一下，我用的是MySQL，而不是MsSQL！
浏览 1提问于2015-03-23得票数 2
对于http请求，我有很多使用ureq的代码，我想知道我是否可以避免使用另一个http库。
我有一个urls列表，我正在调用ureq::get on它们。我想知道我能不能同时打这些电话。如何创建单独的线程并并行执行这些线程？
let v = vec!["www.qwe.com"; 3];
let responses = v.into_iter().map(|s| make_get_request(s)).collect::<Vec<_>>();
浏览 5提问于2021-03-24得票数 0
回答已采纳
我有一个加载到现有Carbon应用程序中的Cocoa插件。
在第一次加载插件时，Carbon应用程序调用一个初始化函数Plugin_Init()，在该函数中，我设置了如下环境：
//this is the global autorelease pool
static NSAutoreleasePool* globalPool = nil;
void Plugin_Init()
{
NSApplicationLoad(); //loads the Cocoa event loop etc
//create an autorelease pool
globalPool=[
浏览 1提问于2010-02-10得票数 0
回答已采纳
2回答
几个单身汉:每个任务一个
、、、、
我有一个C++多线程应用程序，它在单独的线程中运行任务。每个任务都有一个对象来处理和存储它的输出。每个任务创建不同的业务逻辑对象，并可能创建另一个线程或线程池。
我想要做的是为由任务运行的任何业务逻辑对象提供一种简单的方法，以访问每个任务的输出，而无需将“输出”对象手动传递给每个业务逻辑对象。
我看到的是创建输出单例工厂并将task_id存储在TLS中。但问题是，当业务逻辑创建新线程或线程池时，这些线程在TLS中将不具有task_id。通过这种方式，我需要访问父线程TLS。
另一种方法是简单地抓取任务开始后的所有输出。在那个时候会有不同任务的输出，但至少，总比没有好.
我正在寻找任何的建议或想
浏览 3提问于2012-12-06得票数 2
回答已采纳
以前，我做了一些简单的并发基于人造丝的函数。我这样做：
rayon::scope::(|s| {
s.spawn(move |_| {
// Do something
})
})
但是，通过这种方式在spawn上调用s，就会花费一些时间来初始化一个新线程。
但是，如果我构建一个线程池，比如：
let pool = rayon::ThreadPoolBuilder::new().num_threads(8).build().unwrap();
pool.scope(|s| {
s.spawn(move |_|{
// Do somet
浏览 0提问于2021-11-12得票数 1
回答已采纳
1回答
我和有同样的问题。似乎通过更改搜索线程池的队列大小来解决这个问题：
curl -XPUT http://your_es:9200/_cluster/settings
{
"transient":{
"threadpool.search.queue_size":10000
}
}
但是，此API在ElasticSearch5.x中不起作用。
找不到要使用的新API。有什么想法吗？
谢谢!
浏览 0提问于2017-05-19得票数 0
回答已采纳
我有一个经常被调用的带有事件方法的类。假设方法名为: onClicked。在方法内部，我会创建一个线程来做一些事情。
首先，我尝试在event方法中创建一个线程对象。代码如下：
public class MyService {
//Event method
public void onClick() {
new Thread(new Runnable() {
@Override
public void run() {
// do some stuff here
浏览 0提问于2012-04-13得票数 1
回答已采纳
这是一个比代码问题更一般的知识型问题。
我可以使用以下代码创建并行流：
// create List, assign to variable myList
Stream<String> stream = myList.parallelStream();
然而，在web应用程序的世界中，大多数指南建议让容器(JBoss、Weblogic等)为您管理线程和线程池。因此，这引出了我的问题:在web应用程序中使用parallelStream()被认为是一种糟糕的做法吗？
杰森
浏览 0提问于2016-11-07得票数 2
我正在创建一个桌面应用程序来记录各种足球比赛的结果。我使用Java作为我的嵌入式数据库。我的问题是，在每次我想要读/写数据库时，应该使用什么来处理数据库连接管理，而不是创建和销毁连接？我可以找到的大多数示例/教程都非常简单，只有几个方法可以简单地创建一个表、添加一些数据、读取一些数据、结束程序。我希望我正在创建的是更健壮的使用，以及足够的性能，以避免激怒我的最终用户。
如有任何信息等，将不胜感激。作为参考，我正在与Intellij一起使用Java 8 jdk (oracle)。
干杯，斯图
浏览 0提问于2014-11-08得票数 0
回答已采纳
1回答
我想组成一个设置，将我的mongodb连接存储为内存中的3-4个线程，通过这些线程，它将充当一个连接池。当我的核心函数工作时，我不想每次都创建一个连接，因为它会执行一些db查询。我这样想，就像如果我有一个连接池，那么我的核心函数将从池中获取可用的连接(可用的线程)，使用它并将它释放回池。
这有什么意义吗？是否有可能做到这一点？
我知道mongodb内部确实有连接池，但是我希望上面提到的东西在上面。
浏览 2提问于2019-11-19得票数 1
我有一个库(L)，它是由程序(P)使用dlopen动态加载的。L实现了一个插件接口，因此回调它的父接口以获得一些功能。
P内部是一个单例对象，它动态地创建一个线程池对象A。我需要从L访问A。
然而，因为单例是通过使用静态变量来工作的，所以当L被加载时，它最终会创建自己的实例，这在某些情况下是可以的，但我想要在P中创建的实例。有什么方法可以解决这个问题吗？
浏览 2提问于2013-02-21得票数 0
回答已采纳
我在项目列表上运行QTConcurrent::Map来执行一些图像处理任务。这在只有几个线程的机器上工作得很好，但由于我的处理代码的内存需求，在有大量线程的机器上会遇到问题。
是否可以为QTConcurrent操作设置并发线程的最大数量，或者我是否需要使用QThreadPool重新编码，因为我拥有更多的控制权？
谢谢你的建议。
浏览 0提问于2012-07-16得票数 11
回答已采纳
1回答
我有一个独立的应用程序，它使用VMware的，这是一个围绕Webservice客户端的包装器。我使用大小为5的固定线程池来调用库中的API。运行一段时间(一两天)后，内存使用量开始增加，堆转储显示池线程的线程局部变量已经积累了大量内存。
是否存在清除这些线程局部变量的方法？由于webservice调用实际上是从第三方库调用的，所以我无法直接清除线程局部变量。
浏览 1提问于2014-12-18得票数 0
回答已采纳
生成了四个线程，并将它们的范围传递给矩阵，以便执行某些操作。从本质上讲，我的愿望是使用一个for循环，并将工作分解为四个线程。
GE_threaddiv t = new GE_threaddiv(k + 1,toPass + (k+1),k,A[k][k],"1");
GE_threaddiv t2 = new GE_threaddiv(toPass + (k+1),toPass*2 + (k+1),k,A[k][k],"2");
GE_threaddiv t3 = new GE_threaddiv(toPass*2 + (k+1
浏览 30提问于2018-10-20得票数 1
2回答
我在我的解决方案中使用了
我的要求是清除队列并在单击“停止”按钮时优雅地关闭所有线程。
为此，我创建了一个ObjectList
var
List: TObjectList<TMyConsumerItem>;
begin
{ Create a new List. }
List := TObjectList<TMyConsumerItem>.Create();
后来我做了这个修改：
procedure TForm1.DoSomeJob(myListItems: TStringList);
...
for i := 1 to cThreadCount do
浏览 3提问于2017-11-22得票数 0
回答已采纳
1回答
下面是一些使用的Scala猫代码
import java.util.concurrent.{ExecutorService, Executors}
import cats.effect.IO
import scala.concurrent.{ExecutionContext, ExecutionContextExecutor}
import scala.util.control.NonFatal
object Program extends App {
type CallbackType = (Either[Throwable, Unit]) => Unit
// IO
浏览 1提问于2018-09-21得票数 9
回答已采纳
2回答
我想知道使用mixins和singletons的含义。正如我们大多数人都同意的那样，单例是邪恶的，因为他们维护状态，很难跟踪那个状态。特征是优越的，因为它们可以混合在一起，很容易被嘲笑等等。但我想知道幕后发生的事情的实际含义:如何使用mixins不会造成问题？
下面的代码示例只是为了演示我的问题。
方法#1:到处使用单例：
object Server {
def fetchData(input: Input): String = ...
}
object Servers {
val inMemoryServers: Seq[Server] = ...
def randInMemS
浏览 1提问于2015-05-09得票数 0
2回答
我想同时下载多张图片。为此，我使用线程，每个线程使用urllib2模块下载一个图像。我的问题是，即使线程(几乎)同时启动，图像也会一个接一个地下载，就像在单线程环境中一样。
以下是线程化函数：
def updateIcon(self, iter, imageurl):
req = urllib2.Request('http://site.com/' + imageurl)
response = urllib2.urlopen(req)
imgdata = response.read()
gobject.idle_add(self.setIcon,
浏览 2提问于2010-11-10得票数 2
回答已采纳
我已经看了几篇关于这个问题的帖子，但没有一个解决方案对我有效。
下面是我的代码片段：
DBConnector connector = new DBConnector();
MySqlConnection connection = connector.GetConnection();
string select_column = QORTrackingToolLibConstants.DeviationTypeID + "," + QORTrackingToolLibConstants.DeviationTableID;
浏览 1提问于2015-01-02得票数 0
我正在使用Retrofit2。我可以创建几个OkHttp3客户端并与其他客户端共享来自第一个实例的连接池吗？线程安全和良好的实践吗？
浏览 6提问于2016-01-12得票数 2
1回答
Pymongo中的客户端连接
、、、、
MongoClient如何工作并创建连接池或线程创建？
如果创建多个连接，主要资源是什么？
我问的主要原因是这个吗？我在python中创建了多个类，它表示mongodb中单个集合的功能。在每个类中，我都要创建一个客户机。
self.client = MongoClient(hostname, port)
我需要担心哪些资源，性能问题可能是什么？
--如果有办法，我可以沿着所有类共享单个客户端吗？
浏览 1提问于2015-06-23得票数 2
我的Ubuntu18.04内存分配有问题。
( 1 )在线程1中分配一些数据内存，
( 2 )在线程2中再次释放数据并将相同的数据分配给同一个对象，
然后，在步骤(2)中，虚拟存储器和物理存储器将被提高为步骤(1)中的存储器的两倍。我已经使用share_ptr来管理内存，也可以使用val差制运行进程，所以我确信没有内存泄漏。但我想知道，为什么对这一过程的记忆会产生如此大的影响？有三种删除内存的方法吗？
这是我的示例代码，使用两层分层-pymrid结构，顶层是LGMemory，二维向量为shared_ptr，第二级是包含真实数据的修补程序类。步骤(2)在LGMemory::updateData(
浏览 3提问于2020-07-28得票数 0
回答已采纳
1回答
我想知道这是什么
nioEventLoopGroup-2-2
nioEventLoopGroup-2-3
nioEventLoopGroup-5-2
在网络日志(数字)中的意思。这跟线程有关吗？
浏览 1提问于2016-03-15得票数 2
回答已采纳
我有几个问题：
当创建任何自定义调度队列(串行或并发)时，它们在哪个线程上执行任务。
我对GCD文档中的以下文本感到有点困惑
除了创建的任何自定义队列外，系统还会自动创建串行队列并将其绑定到应用程序的主线程。有关获取主线程队列的详细信息，请参阅在运行时获取公共队列。
如果在全局队列上调用dispatch_suspend()或dispatch_resume()会发生什么？
浏览 0提问于2015-04-03得票数 1
我有一个需要并行化的伪代码：
int thread_count=8;
for(int i=1;i<100000;i++)
{
do_work(i,record);
}
do_work函数将基于i工作，并将输出写入记录。现在，我想将这个序列化的实现转换为多线程实现；
我知道我可以做像这样的事情
int thread_count=8;
for(int i=1;i<100000;i++)
{
boost::thread t1(do_work,i,std::ref(record));
}
但这将创建数千个线程，这将损害性能。我相信发布的问题应该是需要multi_threading的最自然的
浏览 0提问于2015-08-20得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
