Questions tagged [concurrency]
In computer science, concurrency is a property of systems in which multiple computations can be performed in overlapping time periods. The computations may be executing on multiple cores in the same chip, preemptively time-shared threads on the same processor, or executed on physically separated processors.
concurrency
23,315
questions
0
votes
0
answers
25
views
ThreadPoolExecutor slows down while running
I have a list of arguments that can be executed in any order. I have written one function to parse and write to an S3 bucket. The function output is a CSV file that's written to the bucket.
def func(...
1
vote
0
answers
53
views
How to reduce cache miss in SPSC queue pop function?
I am working on optimizing a Single Producer Single Consumer (SPSC) queue in C++. The following is the miniman reproducible example for my implementation:
#include <atomic>
#include <cstddef&...
- 31
0
votes
1
answer
28
views
Lambda Provisioned Concurrency showing 0 available. But I'm not using any
I have been using my AWS account for more than 4 months. Now, I need to create a Lambda function with provisioned concurrency. However, it gives the following error:
```The maximum allowed provisioned ...
0
votes
1
answer
124
views
Is this ThreadPool implementation correct?
I am new to concurrent coding and trying to implement simple ThreadPool by myself. I found this implementation on a learning website(jenkov.com) and it seems to be working fine.
However, I think ...
- 111
0
votes
1
answer
65
views
Performance in Go: Mutex vs RWMutex
There are two types of mutex in Go: Mutex and RWMutex
Mutex offers func Lock() and func Unlock().
RWMutex offers those functions plus func RLock() and func RUnlock().
From what I understand, we ...
- 467
1
vote
1
answer
28
views
NextJS Server Actions usage in NextJS API endpoints - concurrent or not?
As I learned by doing: NextJS Server Actions are synchronous.
I want to achieve concurrency; and I like the syntax of having this abstracted; therefore I've created a NextJS API endpoint that has the ...
- 434
0
votes
1
answer
15
views
Jmeter Concurrency call making
I need to trigger a same API 30 times in a second from which only 20 will trigger successfully remaining will failed as we have allowed 20 requests at a time to trigger if it is sent concurrently. ...
- 31
-1
votes
1
answer
52
views
GO Cond - fmt.Println after wg.Done ended up dead lock
Unable to understand this dead lock situation in golang, i have below to go code with pub and sub pattern
package main
import (
"fmt"
"sync"
)
func main() {
cond := ...
- 1,593
1
vote
1
answer
62
views
How to mark Vision text recognition result as Sendable in Swift 6
I have the following code. It simply run Vision API to get the text from the image. I use very simple GCD to dispatch the heavy Vision operation to the background queue, and then dispatch it back to ...
- 1,308
0
votes
1
answer
38
views
Hazelcast race condition?
We run a Hazelcast cluster of 3 machines, each having the same instance of a process. They share amongst others an IMap named waitingMap. In the method activateAnotherBatch() we check for emptiness of ...
- 81
-1
votes
1
answer
66
views
Why does Tokio single threaded flavor not provide any concurrency?
When I am running the below code with flavor = "current_thread", I am seeing output only from first task and not the other. My understanding was that even in a single threaded execution, ...
- 647
0
votes
2
answers
78
views
Testing concurrency of a collection with XUnit provides different results
I have a concurrent class called ClientManager that uses a hashset and a ReadWriterLock to register my "clients" through their Guid:
internal class ClientManager : IClientManager
{
...
- 11
0
votes
0
answers
37
views
Crash | Can't access Looper on Coroutines Dispatchers.IO
I'm executing some tasks on Coroutines Dispatchers.IO like this to achieve concurrency:
fun postMessage(request: Request) {
CoroutineScope(Dispatchers.IO).launch {
val requestHandler = ...
1
vote
0
answers
28
views
Why does Folly's `rcu_domain.retire(list_node* node)` require non-blocking `half_sync`?
I've been examining Folly's implementation of RCU.h, particularly how half_sync is used within the retire function. The relevant snippet is shown as follows:
void retire(list_node* node) noexcept {
//...
- 11
0
votes
1
answer
25
views
How can I let higher priority Slurm jobs pass through while not sharing individual CPUs among tasks?
My IT department kindly set me up with a Linux VM with Slurm and I'm learning commands. I'm changing numbers a bit, but let's say there are 2 nodes each with 5 cores/CPUs (I think they're the same ...
- 1