multithreading

    0热度

    1回答

    我的问题是关于特定操作的成本科特林数据类copy()操作和RxJavaobserveOn()线程切换的成本。 我有一个系统产生事件,比如说Schedulers.mainThread。事件是Kotlin数据类别。接下来是业务逻辑,最后,链条产生新的数据类别通过copy()操作。所有结果必须在Schedulers.mainThread上消耗。因此,链看起来就像是: eventSource() //Ev

    1热度

    1回答

    在内核空间中进行调试时,我有时希望根据线程组中的回溯帧搜索线程,如特定任务上的所有线程。 例如,获取kernel_task ID (lldb) showalltasks task vm_map ...command 0xffffff800d828550 0xffffff800a1038d8 ...kernel_task 转储全部线程属于kernel_task (ll

    -2热度

    1回答

    我有一个WPF C#应用程序,它使用分派器计时器来更新UI。 在线程A中,在类DataProcessor中,我更新了一个变量,一个名为'FinalMarkers'的自定义结构。 static readonly Object mLock = new Object(); static List<Storage.FiducialMarkers> finalMarkers; p

    1热度

    1回答

    更新: 总之,我有一个消息发送从用户到服务的队列。 但是,当一个服务获得1000条消息时,比队列由 支配,它和其他服务在队列为空之前不会收到消息。我需要这种方法的解决方案。 我对我的BlockingQueue有问题。比方说,我有100个外部服务,我负责向他们发送消息来自用户。 用户 - >我 - >第三方。 我在我的应用程序中使用队列。当其中一个第三方服务不可用时发生问题: 从用户接收到任何第三方

    0热度

    1回答

    我读过,当您在单独的线程(并行)中运行长时间运行的操作时,当您的PC具有多个处理器内核时,性能将有显着改善。在C#中有一个函数Parallel.ForEach,我的理解是,它在每个处理器核心上运行的独立线程中拆分长时间运行的操作。尽管如果只有一个内核,该函数将作为简单的Foreach循环(同步)运行。另外,如果您创建的线程多于处理器内核,则可能会产生负面影响。 我正在考虑创建一个单独的控制台应用程

    2热度

    1回答

    我想做一个同步排球网络请求。我正在使用请求期货等待响应,但future.get()通话总是超时(不管超时设置为多长时间)。我已经单独测试了每个组件,除了使用未来之外,没有任何东西似乎导致了错误。关于我在这里没有错的任何想法? Activity.java:persistData() postCampaign(campaign); Activity.java:postCampaign() priv

    2热度

    1回答

    我有一个关于ThreadPoolExecutor vs Thread类的性能问题,在我看来,我缺乏一些基本的理解。 我有两个功能的网络刮板。首先来分析一个网站主页和第二的每个图像的链接,加载图像关闭解析链接: import threading import urllib.request from bs4 import BeautifulSoup as bs import os from c

    0热度

    1回答

    我的程序应该在多线程中运行很长时间。 我需要为线程设置超时的能力,一旦线程终止,我想再次启动它。 这里是我的代码: @Test public void testB() throws InterruptedException { final ExecutorService threadPool = Executors.newFixedThreadPool(2); f

    1热度

    3回答

    我正在编写一个Java API,并且正在使用MySQL。线程安全读取和写入数据库的最佳做法是什么? 例如,采取以下createUser方法: // Create a user // If the account does not have any users, make this // user the primary account user public void createUser(

    0热度

    4回答

    我想在Clojure中创建一些未来,并在特定的线程上运行它们,以确保它们一次运行一次。这可能吗? 将Java库包装起来并不难,但在这之前我想确保我不会错过Clojure的做法。在Java中,我可以通过执行FutureTask并将这些任务提交给单线程执行程序来执行此操作。