首页 文章
  • 2 votes
     answers
     views

    PrintGCApplicationStoppedTime

    我有JVM选项-XX:PrintGCApplicationStoppedTime打印真正的“GC停止世界时间” . 例: 应用程序线程停止的总时间:0.0018219秒 应用程序线程停止的总时间:0.0016542秒 应用程序线程停止的总时间:0.0015797秒 我需要通过java代码计算“GC停止世界” . 我该怎么做 ?
  • 0 votes
     answers
     views

    线程时asyncio aiohttp错误

    我有一个为我编写的脚本,我无法执行它...我收到以下错误... 回溯(最近的呼叫最后): 文件“crawler.py”,第56行,在loop.run_until_complete(future)文件“C:\ Users \ lisa \ AppData \ Local \ Programs \ Python \ Python37-32 \ lib \ asyncio \ base_events....
  • 77 votes
     answers
     views

    C volatile关键字是否引入了内存栅栏?

    我知道 volatile 通知编译器可能会更改该值,但为了完成此功能,编译器是否需要引入内存栅栏才能使其工作? 根据我的理解,易失性对象的操作顺序不能重新排序,必须保留 . 这似乎暗示一些内存栅栏是必要的,并且没有真正解决这个问题的办法 . 我说的是对的吗? this related question有一个有趣的讨论 Jonathan Wakely writes: ...对于不同的volati...
  • 1 votes
     answers
     views

    C中的同步意味着什么

    我正在阅读关于 const 和C 11中的线程安全性,这里是一个相关的Stack Overflow question,这里也是Herb Sutter的video . 经常提到"synchronized"这个词 . 但"synchronized"到底意味着什么呢? 例如,以下两行来自Herb的视频 “在没有同步的情况下从多个线程中复制同一个对象”(在13:40...
  • 4 votes
     answers
     views

    使用Kafka在应用程序上打开太多文件错误

    我正在使用Kafka和Spark Streaming构建应用程序 . 输入数据来自第三部分流媒体,并在kafka主题上发布 . 此代码显示了Stream Proxy模块:这是我从流式传输中获取结果以及如何将它们发送到KafkaPublisher的方式(它只显示了草图): def on_result_response(self,*args): self.kafkaPublisher.push...
  • 0 votes
     answers
     views

    在控制台应用程序上轮询Kinect传感器

    我需要创建一个使用Kinect的控制台应用程序,使用Kinect SDK和c# . 由于它是一个控制台应用程序,我发现轮询是检索我需要处理的帧的最佳方法 . 我需要从深度相机和rgb相机中检索帧,然后在单独的线程中进行一些处理(一个用于深度图像,一个用于rgb图像),并为两个中的每一个提供输出给用户处理过的帧 . 我一直在考虑这样做的方式如下: 1 - 创建2个线程,第一个是轮询rgb摄像头并进...
  • 1 votes
     answers
     views

    使用Thread和Semaphore的代码

    这段代码我做错了什么?它就像一个票务系统,你有不同的卖家,卖34张票 . #include <stdio.h> #include <stdbool.h> #define NUM_TICKETS 35 #define NUM_SELLERS 4 /** * The ticket counter and its associated lock will be accessed...
  • 0 votes
     answers
     views

    TypeError:无法将feed_dict键解释为Tensor

    我正在使用线程方法将多个客户端放到一台服务器上 . 我正在使用带有resnet50的预训练模型来预测某些东西 . 我的预测代码是 def prediction(array): array = np.array(array , dtype = np.float64) array = np.reshape(array, (1,224,224,3)) #print(array.s...
  • 7 votes
     answers
     views

    jMeter线程序列

    我有一个JMeter测试计划,其中包含以下http请求采样器 . 登录 调用一些需要登录用户的功能 退出 当我用5个并行线程执行测试计划时,我看到在为某些线程调用sampler 1之前调用了采样器2,然后调试器声明失败 . 有没有办法指定要执行的采样器序列?
  • 1 votes
     answers
     views

    当多个用户登录时,如何控制Jmeter的执行?

    我已经使用现有用户记录了一个脚本,用于维基页面记录的操作; 登录 创建一个页面 编辑页面 退出 我使用事务控制器元素分隔了上述操作 . 然后我使用CSV数据集配置元素添加了用户列表(100个用户)来测试计划 . 现在用户(100个用户)登录系统,然后所有用户一次创建维基页面,创建过程后所有用户编辑页面,编辑操作结束后,所有用户都从系统注销 . 但我想将上述情况改为: 用户1:登...
  • 299 votes
     answers
     views

    如何在Android中以定义的时间间隔运行Runnable线程?

    我开发了一个应用程序,在Android模拟器屏幕中以定义的间隔显示一些文本 . 我正在使用 Handler 类 . 以下是我的代码中的代码段: handler = new Handler(); Runnable r = new Runnable() { public void run() { tv.append("Hello World"); ...
  • 257 votes
     answers
     views

    从另一个线程在主线程中运行代码

    在android服务中,我创建了一些用于执行某些后台任务的线程 . 我有一种情况,线程需要在主线程的消息队列上发布某些任务,例如 Runnable . 有没有办法获得主线程的 Handler 并从我的其他线程发布 Message / Runnable ? 谢谢,
  • 5 votes
     answers
     views

    具有异常处理的Python 生产环境 者/消费者

    我正在尝试编写一个看似简单的经典 生产环境 者实现 - Python中的消费者习语 . 对于多个较慢的消费者,有一个相对较快的 生产环境 者 . 原则上,使用Queue模块很容易做到这一点,而库文档只有几行代码 . 但是,我还希望代码在异常发生时正常工作 . 如果发生以下任何事情, 生产环境 者和所有消费者都应该停止: 生产环境 者因例外而失败 任何消费者都因例外而失败 用户停止程序...
  • 0 votes
     answers
     views

    没有经纪人如何将消息传递给消费者

    Producer 具有自己的SynchronizedBlockingQueue的不同线程 . 每个 生产环境 者都将消息放入自己的队列中 . Consumer 不同的线程将从任何一个队列和启动过程中获取消息 . 现在为了沟通 生产环境 者和消费者,我们需要经纪人 . 这可能是瓶颈 . 消费者是否有任何其他方式从任何 生产环境 者和启动过程中获得一条消息 .
  • 7 votes
     answers
     views

    使用具有多个线程的rabbitmq消息队列(Python Kombu)

    我有一个RabbitMQ交换与一个队列 . 我希望创建一个运行多个线程的守护进程,并尽快通过此队列 . “工作”涉及与外部服务进行通信,因此每个消费者中将会有相当多的阻止 . 因此,我想让多个线程处理来自同一队列的消息 . 我可以通过在我的主线程上使用队列来实现这一点,然后将传入的工作转移到其他线程池中,但是有没有办法在每个线程的上下文中启动多个使用者?
  • 0 votes
     answers
     views

    使用spring amqp在RabbitMQ服务器中进行多线程的消费者配置?

    我们正在使用Spring-AMQP实现RabbitMQ,我们的要求是在多个线程中运行使用者以使用来自单个队列的消息 . 是否需要执行任何服务器(RabbitMQ)端脚本或我们可以在消费者级别为单个队列运行多个线程的任何其他方式? 提前致谢!
  • 8 votes
     answers
     views

    从python线程中消耗rabbitmq队列

    这是一个漫长的过程 . 我有一个用户名和密码列表 . 对于每一个我想登录帐户并做一些事情 . 我想用几台机器来更快地完成这项工作 . 我想这样做的方法是有一台主机,它的工作就是有一个cron,它不时检查rabbitmq队列是否为空 . 如果是,请从文件中读取用户名和密码列表,然后将其发送到rabbitmq队列 . 然后有一堆订阅该队列的机器,其作业正在接收用户/通行证,在其上做东西,确认它,然后转...
  • 0 votes
     answers
     views

    为多个 生产环境 者和消费者排队

    我必须在.Net3.5中编写多个线程(现在至少3个)之间的通信,并且每个线程都是 生产环境 者和消费者 . 而不是在每对线程之间发送信号,我的想法是实现一个消息队列,它将存储类,如下所示: enum Signals { ObjectArrivedOnLightBarrier, ObjectLeftLightBarrier, CodeFound }; enum UnitID { GrabThread...
  • 151 votes
     answers
     views

    线和光纤有什么区别?

    线和光纤有什么区别?我听说过来自红宝石的纤维,我读过听说它们可以用其他语言提供,有人可以用简单的语言向我解释一下螺纹和纤维之间有什么区别 .
  • 175 votes
     answers
     views

    什么是“线程”(真的)?

    我一直试图找到一个好的定义,并了解一个线程到底是什么 . 似乎我必须遗漏一些明显的东西,但每当我读到一个线程是什么时,它几乎是一个循环定义,一个“线程是一个执行线程”或“一种分为运行任务的方法” . 呃呃 . 咦? 从我所读到的看来,线程并不是真正具体的东西,就像进程一样 . 它实际上只是一个概念 . 根据我对其工作方式的理解,处理器为程序执行一些命令(已被称为执行线程),然后当需要切换到某个其他...
  • -4 votes
     answers
     views

    进程和线程之间的技术差异是什么? [重复]

    这个问题在这里已有答案: What is the difference between a process and a thread? 33答案 我感觉像'过程'这样的词被过度使用,还有硬件和软件线程 . 如Erlang这样的语言轻量级进程怎么样?是否有明确的理由使用一个术语而不是另一个术语?
  • 2 votes
     answers
     views

    使用datastax java驱动程序异步写入cassandra的有效方法?

    我使用datastax java驱动程序3.1.0连接到cassandra集群,我的cassandra集群版本是2.0.10 . 我与QUORUM一致性异步编写 . public void save(final String process, final int clientid, final long deviceid) { String sql = "insert into ...
  • 2 votes
     answers
     views

    这段代码中是否存在潜在的饥饿或仅仅是我?

    我正在努力学习Scala,并发现它是一种很棒的语言 . 我从大卫波拉克那里学习"Beginning Scala" . 在第3章中有一段代码,它说明了如何在没有synchronized块的情况下编写多线程代码(这段代码是从书中复制的,可以从Apress site下载,我不打算在这里违反任何法律): import java.util.concurrent.atomic.{Atomi...
  • 0 votes
     answers
     views

    Scala期货在演员中创造无限线索

    我在actor中使用future和timeout来避免系统等待多长时间执行命令: val _output = future { "myCommand.sh" !! } output = try { Await.result(_output, 3 minutes) } catch { case e: TimeoutException => { ...
  • 3 votes
     answers
     views

    如何在Scala / Akka中处理无限的未来?

    我的问题是 - 我使用Scala和Akka - 其中一项工作是通过第三方SDK使用外部API . 问题是我无法控制这个SDK,而且,我应该期待内部发生任何事情,甚至无限循环 . 我“解决”了这样的问题 Await.result( Future { sdk.makeSomeCall()}, 1.minute) 所以我的代码不会永远阻止 . 但是,我开始通过使用简单的 Thread.sleep()...
  • -1 votes
     answers
     views

    如何使用Akka Actor永远运行一个守护进程?

    我的项目是 not ,使用 Akka 截至目前,它作为一个进程运行,并做了太多的事情 . 作为第一个初始步骤,我们正在尝试将脚手架放置到位,以便我们获得Fault Tolerance . 例如, ProjectSupervisor|ExistingProcessActor ExistingProcessActor 将作为一个永远长期运行的工作运行,如果因为一些 Exception ...
  • 0 votes
     answers
     views

    未来{blocking {created new Future {}}} - 嵌套期货会阻止父母一个人

    我试图在实际代码中模拟我的情况 . 用例很简单:有: Future {blocking { // in there it calls nested futures }} 更详细的(全局执行上下文用作父级,但有一个尝试使用separete one for children): object ExContexts { val main = scala.concurrent.Ex...
  • 53 votes
     answers
     views

    等到任何Future <T>完成

    我有很少的异步任务在运行,我需要等到它们中的至少一个完成(将来我可能需要等待N个任务中的util M完成) . 目前他们被呈现为未来,所以我需要类似的东西 /** * Blocks current thread until one of specified futures is done and returns it. */ public static &lt;T&gt; Future&lt...
  • 4 votes
     answers
     views

    Java 8可完善的未来

    我的问题是如何使用Completable Future . 我有一个实现Callable的类 . public class Executor implements Callable&lt;Collection&gt; 早先用来做 - service.submit(collectorService); 哪个会返回 Future&lt;Collection&gt; . 但是我们不想再使用未来,需...
  • 2 votes
     answers
     views

    如何在Java中实现非阻塞期货

    Java Future对象用于获取由并行线程(Executors)执行的异步计算的结果 . 我们调用Future.get()方法并等待结果准备好 . 此示例显示了从Future检索结果的非阻塞方式 . java-implement-java-non-blocking-futures . NonBlockingExecutor executor = new NonBlockingExecutor(...

热门问题