我有一个函数，它使用concurrent.futures.ThreadPoolExecutor在另一个函数运行时显示进度条。bar_length - i - 1)}") time.sleep(0.2) 然而，它仍然每隔0.2秒轮询一次，以查看派生的函数是否完成。虽然这样可以工作，但我想知道是否有更有效的方法来通知run_with_loading函数它启动的function已经<
浏览 11提问于2020-10-12得票数 0
回答已采纳
1回答
我有一个在ZMQ Poller上轮询的线程：这个线程也是在计票器中注册的套接字上接收并发送回消息的线程。那么第二个问题是:在poller线程中注册套接字是否安全？大多数情况下，执行轮询的线程都在忙着做其他事情，但可能会发生轮询等待超时的</e
浏览 4提问于2015-11-16得票数 2
所以我有一些代码，我正在创建6个线程，在我的主线程中，运行一些代码。我启动了线程。然后，我在线程上调用join()，这样主线程会等待它们全部死亡，然后再继续执行。现在，我正在使用一些非常基本且很可能不准确的方法来衡量我的代码运行所需的时间。只需调用以获取开始和结束时的系统时间，然后打印差值。
比方说，运行我所有的代码需要大约500ms。我决定为每个线程删除对joi
浏览 1提问于2013-11-11得票数 2
1回答
我正在处理一个遗留的同步服务器，它的操作运行时间长达一分钟，并公开了3个端口来解决此问题。有“轻请求”端口、“重但重要”请求端口和“重”端口。它们都公开相同的服务，但由于它们在不同的端口上运行，因此它们最终都有专用的线程池。 现在这种方法遇到了负载平衡的问题，因为特使无法处理在3个不同端口上公开相同proto的单个服务。我正在尝试提出一个可以工作的单线程池配置(可能是一个过度配置<
浏览 250提问于2020-10-19得票数 1
3回答
到目前为止，我已经尝试了许多方法来寻找解决方案，但没有找到合适的方法。std::thread rsync_t(&PreCompile::RunPreCompileThr, obj, arg1, arg2);现在，的目标是定期检
浏览 2提问于2020-01-22得票数 0
回答已采纳
例如，如果我想删除一个任务，我可以这样做(例如，第一个任务)我现在的问题是，如果我想要取消的任务目前正在调度器线程中运行，我必须在主线程中等待，直到任务被取消。我想我可以用这样的get()来做这个：myTaskList.get(0).getTask().get();
但是我的主线程继续进行，而不等待任
浏览 6提问于2012-02-20得票数 1
我有一个简单的实用程序，它可以ping一组节点，并将字符串的ArrayList返回给将来要输出到文件的对象。程序应该一直运行，直到被用户终止。无论并发运行的线程数是多少(总是小于100，由输入文件决定)，我只输出第一个和最后一个初始化线程的结果。作为一个健全性检查，我创建了一个全局变量，每个线程将在关闭并将其结果返回给Future对象之前发送其结果。所有线程都会正
浏览 0提问于2013-04-11得票数 1
回答已采纳
1回答
理想情况下，人们可以：connect(future, this, &MyObject::resultOfFuture);
然后将resultOfFuture实现为获取一个参数的槽:来自std::future<int>的int值。我添加了这个建议作为对的评论。我最喜欢这样做，因为我的大部分未来/承诺无论如
浏览 0提问于2017-11-16得票数 2
2回答
我使用python 3.6来同步多线程。我有一个“主线程”，它为所有其他线程提供工作。当工作线程完成工作时，它会向主线程发出信号，让它为其分配更多工作。为了实现这一点，主线程在收集要处理的新数据之前等待一个(或多个)线程完成。我想以这种方式升级它:在一个工人完成它的工作后，它向“主</
浏览 24提问于2018-02-20得票数 0
回答已采纳
1回答
跟踪并发任务
、、
我正在编写一个针对SQL Server的轮询系统。当检索到任务时，使用Task.Factory.StartNew()将它们卸载到新线程。整个过程都在一个无限循环中，我希望只允许N个并发任务。，也不确定如何清理已经完成的任务。如果我将清理代码放在任务本身中，我可以使用List<Task>和Task.CurrentId属性来标识集合中的项，但我不相信我可以在任务本身中处理集合中的任务
浏览 1提问于2012-07-25得票数 0
回答已采纳
8回答
螺纹约束
、、、、
我在实践中阅读Java并发，并将其与线程限制概念混淆起来。书上说
当对象受限于线程时，即使受限对象本身不是线程，这种使用也是自动线程安全的。那么，当一个对象被限制在一个线程时，没有其他线程可以访问它？这就是被限制在一根线上的意思吗？如何将
浏览 6提问于2011-06-07得票数 44
回答已采纳
我尝试等待从任何boost::asio::async_函数返回的std::future对象(使用use_future)。(); // lasts forever after io_service.stop();runner_ = std::thread([this]() {
boost::asio::io_serv
浏览 0提问于2016-02-26得票数 3
1回答
在使用线程和队列时，我注意到了一些难以理解的行为。我花了很长时间浏览google，但仍然没有找到我理解的解释，所以我希望有人能帮我解决问题。
我有这样的功能..。这基本上相当于在线程之外运行stat_somedir()，或者使用线程运行它并使用time.sleep()。为什么在检查线程时添加time.sleep(1)使stat_somedir()运行得更快？(我制作了另一个版本，而
浏览 3提问于2014-10-13得票数 0
1回答
我在基于python docker SDK的应用程序中使用aiohttp。我的目标是在请求出现时启动一个容器，等待它完成所有工作并返回一个响应。我想同时处理许多这样的请求。问题是如何定义容器何时完成工作。Container包的docker实例有一个方法wait()，但是它是阻塞的，所以我不能“就这样”使用它。所以我想出了其他的方法:启动一个容器，创建一个新的异步任务，并且(在这个任
浏览 4提问于2021-02-26得票数 0
3回答
关于java.util.concurrent包和Future接口，我注意到(除非我弄错了)，只有SwingWorker实现类才具有启动冗长任务和查询进度的能力。这就引出了以下问题：
在非GUI、非Swing应用程序(想象控制台应用程序)中，有没有办法在后台启动一个冗长的任务，并允许其他线程检查进程？在我看来，没有理由将此功能限制在swing / GUI应用程序中。否则，在我看来，唯一可用的选择就是执行ExecutorServ
浏览 0提问于2010-02-17得票数 14
回答已采纳
1回答
我有一个应用程序，它在其主线程中执行一些数据处理。到目前为止，它是一个纯粹的控制台应用程序。现在，为了可视化目的，我不得不添加一个QT，并将其作为一个单独的线程执行。如果QT窗口关闭，主线程当然仍然运行。一旦窗口关闭，我如何终止主线程？True: time.sleep(2)
if __name__ == "__main__": main()
我最好的<
浏览 9提问于2022-04-07得票数 1
回答已采纳
1回答
处理服务器端长轮询的最佳方法
、、、、
我有一个用例，需要每1秒轮询API (基本上是无限时间循环)。轮询将由用户通过外部系统动态启动。这意味着可以同时运行多个轮询。当API返回400时，将完成轮询。无论如何，我当前的实现看起来像是：
Flask应用部署在heroku上。 flask应用程序有一个端点，外部系统调用它来启动轮询。使用烧瓶端点的会将消息添加到队列中，工作人员一收到消息，它就会开始轮询。我正
浏览 1提问于2020-01-17得票数 3
我看过Java中关于析构函数的帖子，了解到Java没有析构函数，但我很困惑，如果没有析构函数，我的应用程序需要做什么。
我的应用程序允许用户创建一系列的网络爬虫，这些爬虫保存在一个数组列表中。每个crawler都有一个进度面板gui，显示已爬行的页面等，并允许用户暂停该爬虫。但是，用户可能还想“终止”该爬虫程序。应该注意的是，Crawler类的每个实例都有一个Scraper类的实例，而Scraper类又有一个Data
浏览 4提问于2011-07-08得票数 0
回答已采纳
云服务器
ICP备案
实时音视频
云直播
对象存储
腾讯云开发者
