multithreading

0热度

1回答

我期望获得100,000个请求，其中至少有100个请求是并发的。每当我收到请求时，我都会创建一个新线程，并在使用pthread_exit()完成后将其销毁。使用pthread_detach我获得99％的成功率。有没有比这更好的方法？ pthread_t hilo; // infinite loop while ((client_sock = accept(server_sock, (struc

0热度

1回答

在Node.js中锁定承诺链接

我有一个REST API，它会一个接一个地执行一系列异步任务。代码如下所示： asyncFunc1() .then(asyncFunc2()) .then(asyncFunc3()) .then(asyncFunc4()) 第一步将执行一些数据库查询，最后一步将更新数据库。当然（因为我来自java/c + +背景），我会在我的承诺链的开头添加一个锁，以确保与数据库的交互受到保护。但我是

0热度

1回答

Python中的并行或事件驱动函数？

我对Python相当陌生，所以也许我应该如何工作的整个概念是错误的：我正在为时间管理目的构建RFID阅读器。例如。用户使用RFID芯片登录 - >计时器开始每隔一分钟计算并更新Google电子表格。更新部分工作正常，但需要一段时间。但我想一直检查RFID登录。我读过的地方就是我正在寻找的事件驱动编程。目前我正在做一切在一段时间的真正的循环，这感觉就像一个黑客本身。我能以某种方式在RFID阅读器

0热度

2回答

从LinkedBlockingQueue中删除元素时，我的下面的代码线程安全吗？

我有一个下面的方法，它被多个线程同时调用来获取活动套接字。它需要LinkedBlockingQueue作为参数，然后我迭代，看看是否有liveSocket可用，如果它可用，然后我删除并返回该套接字。 private Optional<Holder> getSocket(final LinkedBlockingQueue<Holder> endPoints) { Optional<Hold

0热度

3回答

是否从MainActivity和碎片复制线程开始服务？

我从MainActivity以及Fragment开始后台服务。它会创建重复线程吗？所以这将是2服务运行？ MainActivity protected void onCreate(Bundle savedInstanceState) { //... context.startService(new Intent(context,gps_service.class)); //

1热度

1回答

瓶服务器退出时线程仍然运行

正如标题所述，我创建了一个单独的线程来执行Flask中的长任务。 import schedule import time start_time = time.time() def job(): print("I'm working..." + str(time.time() - start_time)) def run_schedule(): while Tr

0热度

3回答

当数据准备就绪时，从改造的警报Mainthread

我有一个改造请求，当我在onResponse中获取数据时，我在上面的代码中称为繁重工作的文本视图中插入了倍数，我从OnReponse得到结果，否则我会从数据库中得到结果，所以问题是我在OnResponse和OnFailure中有相同的代码，所以有任何方法可以将我繁重的工作放在改进之外，并等待响应只从OnResponse或OnFailure获得一个结果？ call.enqueue(new Call

0热度

2回答

Java的挥发性，同步，原子例如

您好我正在读Java并发在实践中，我读有趣的说法指出，锁定既能保证可见性和原子;易变的变量只能保证能见度。任何一个可以请解释，如果变量声明为挥发性所有其他线程读取更新获得价值那就是为什么我关心像声明中的原子：counter = counter + 1; 在此先感谢。

1热度

1回答

Python的多线程服务器可以在同一时间

我玩弄了解多线程处理一个客户端的消息，所以我写了下面的客户机/服务器应用程序，其中，服务器发送命令给客户端，客户端检查此命令，如果它等于到'a'它发送一个回复到服务器。在我创建了两个插槽和一个线程的服务器代码;第一个套接字将命令发送（发布）到所有连接（订阅）的客户端。在线程第二插座等待来自客户的任何答复，但因为线程执行一些阻塞的操作（如存储客户端在数据库中发送的信息），它可以在同一时间，即使插座

0热度

2回答

RxJava和一些编码与rxjava它让你想在一个完全不同的方式，我仍然无法理解我应该怎么做时，我想要一些操作的一些数据保存在集合中（后收藏

保存数据可以说地图的一个关键的价值），以便在所有请求完成后稍后处理。例如可以说我想发出一些对某个API的调用，并在地图中保存所有失败的调用响应，以便稍后进行一些“错误更正”。直到现在它看起来像我需要从上到下写整个流程来做这个请求 - >错误 - >纠正这是一个操作管道，我想分离到两个不同的操作发生在不同的时间。我意识到我可能错过了rxjava的一个关键概念。总之我怎么之外缓存数据的集合在以