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.
2
votes
0answers
31 views
Comparing Java Semaphore versus ReentrantReadWriteLock
In this post, I attempted to compare the performance of two concurrency constructs:
java.util.concurrent.Semaphore,
...
2
votes
0answers
61 views
Many-readers-one-writer with semaphores and multithreading
I've been looking for a solution to the may readers one writer in Java.
I was intrigued by this question posted here and I read the Wikipedia entry about it.
So far, I've reached a fine solution, or ...
4
votes
0answers
74 views
Safely executing background tasks in parallel in ASP.NET Core
Context and initial idea
I'm trying to teach myself the CQRS and Event Sourcing patterns by developing a simple ASP.NET Core application, loosely following Greg Young's example CQRS implementation on ...
6
votes
1answer
58 views
Quiz game with timer
This is my first Go program. I would like to know what could be improved, what is done wrong, and anything else that I should know. The CSV contains 10 questions with the 10 answers separated by a ...
3
votes
2answers
75 views
Download and save bulk URL concurrently
I am new to Go and wrote program to download and save bulk URLs concurrently. It is working correctly, but I would like to make it more efficient and follow best practices.
...
3
votes
2answers
76 views
java Thread-safe LRUCache implementation
What is best way to implement thread-safe LRUCache in java?
Please review this one.
Is there any better approach which can be taken here?
...
0
votes
1answer
83 views
Finding the longest Collatz sequence using Go, concurrently
I am working through this problem on project euler.
Basic purpose of the code:
...
0
votes
0answers
26 views
Mutex implementation using Windows APC
I just wrote this now and didn't test it much. This isn't a replacement for std::mutex, but for something like fun. I may develop it to make it shared across processes by storing the counters in a ...
4
votes
1answer
72 views
Reader Writer SpinLock
I'm quite new to C++ and want to focus on writing performant multithreaded code because I will try to port our company internal GUI framework which is currently implemented in C#. So I'd love to get ...
0
votes
0answers
19 views
Dynamic “compilation” of SQL stored procedures
I have a stored procedure which is called to create ( "compile" ) temporary stored procedures, code below, based on whether a flag in a database record is set - the various sub-procedures such as ...
4
votes
2answers
61 views
Upload a directory, in parallel, to an artifact repository
This code uploads an entire directory and allows for its reparenting on a remote server (an artifact repository).
Three concerns:
Copying the files locally takes a lot of space. Ideally, I could use ...
1
vote
2answers
92 views
Golang execute several go routine in loop and then wait
I'm new in Go and excited with its easy-to-use concurrency implementation. However I'm not sure if I'm doing it right in Golang way.
Consider the code where I spawn ...
2
votes
1answer
43 views
Batch downloading to file or memory
This is likely my first useful piece of Rust code. Planning to crate-ify it. It works.
...
5
votes
2answers
102 views
Using two threads to increase RFC1951 Deflate compression performance
I have modified my implementation of RFC 1951 "Deflate" compression to use two threads. One thread performs the LZ77 matching, looking for sequences of at least three bytes that occur earlier in the ...
0
votes
0answers
19 views
Go wrapper around io.Writer that tracks the number of bytes written
The code below implements ProgressWriter, a wrapper around io.Writer that can track the number of bytes written, and a function <...
5
votes
2answers
75 views
Automatic RAII wrapper for concurrent access
Probably many people had to work with multithreaded applications with C++ and can understand how messy can be fine-grained locking of objects.
So once in a while I came to idea of implementing some ...
1
vote
0answers
59 views
Critical section around given key
I would like to know if there is any pre-existing implementation of my solution so I don't have to reinvent the wheel.
What I'm trying to create is an utility which allows me to create critical ...
0
votes
0answers
44 views
JNI: porting a semaphore data type to Windows
I have this JNI code to review. The demo driver + irrelevant porting code is here.
semaphore_impl.h:
...
2
votes
1answer
57 views
Reading shards from a Kinesis stream
Here is part of my implementation of reading a Kinesis stream. I am not confident that this is the best way to implement synchronizing returns from goroutine.
Assuming there are N shards in the ...
3
votes
2answers
103 views
Go grep command clone
I am trying to make a simple clone of the command line utility grep. I'm working on it just for fun and to practice Go. The thing is, I am trying to make it in a way that if several files are given at ...
4
votes
1answer
447 views
Concurrent observable collection
I'm working on a WPF 4.5 desktop application that has several nested collections with the following key aspects:
writes mainly from UI thread, but also from worker threads
writes are relatively ...
1
vote
0answers
175 views
Golang gRPC context to check if cancelled or if deadline is exceeded while running function code
I am writing a gRPC Golang application and am looking for the best way to check if the deadline is exceeded or if the client cancelled the call.
On the server side I created a channel called ...
3
votes
0answers
72 views
Linked list with hand-over-hand locking
Follow-up to this question: after reading the comments, I decided to redesign my linked list to have a cursor that only contains one node and implement the interface similar to the one of forward_list ...
5
votes
1answer
112 views
Specialized ConcurrentLinkedList
I need a concurrent data structure with the following properties:
Low overhead for enumeration
Insert only at end.
Removal from any point.
Enumeration should be safe with concurrent writing
...
0
votes
0answers
25 views
Running a JavaFX 11 interface update at regular intervals (in Kotlin)
I want to update a field on a JavaFX 11 UI in response to a thread which retries a process every second and updates statusString with the result. Since the ...
3
votes
0answers
57 views
Override prototype inside of constructor of ES6 class for dependency injection
We implemented a small dependency injection mechanism which we use in our project. Now after 2 years of developing our project we need our classes to know who instantiated them via dependency ...
0
votes
0answers
39 views
Using ReadWriteLock to implement a cache access guard
In my project, there is an internal cache api to use. I have noticed an emerging pattern such that:
...
1
vote
1answer
138 views
Rust Task Queue
The purpose of this program is to have one thread (main thread) working on I/O reading lines from a file and feeding it to a pool of worker threads whose job is to perform some processing on each line ...
2
votes
0answers
34 views
Comparing performance of multi- and single - thread search of a maximum number
I have a class that compares the performance of two methods (multi- and single- thread) that searches for maximum number in the string of numbers. I want to improve the performance of a multithreaded ...
1
vote
0answers
133 views
Thread-safe Java class for managing XML files <> domain models
This Java class (aka application component) role is to handle a series of XML files stored in the file system. It must convert those XML files to the corresponding application domain model, and it ...
7
votes
4answers
672 views
Caching Color-Bitmaps as MemoryStreams
I am in the need to cache Bitmap's in a memory-optimized way because the API I am building will need to process many colored ...
1
vote
1answer
110 views
Concurrent usage of resources
Please take a look at the following code. This is my attempt at understanding concurrent applications.
...
1
vote
1answer
122 views
Run two computations in parallel, and return the results together
I am reading the "Learning Concurrent Programming in Scala" and there are exercises in the end of each chapter.
One of exercises is
Implement a parallel method which takes two computation blocks a ...
2
votes
1answer
38 views
ProcessPoolExecutor KMZ file search
I've written a script to look for coordinates in KMZ files. I've tried to speed execution up using the ProcessPoolExecutor. I'm quite new to Python, so any recommendations are more than welcome.
<...
0
votes
1answer
38 views
Reading a user credentials from file concurrently [closed]
I came across the following code snippet:
...
4
votes
0answers
287 views
Custom TaskScheduler: Limited concurrency level
I'm interested in some feedback for a custom TaskScheduler implementation I wrote today for use on a game server - I wanted to be able to have a single-threaded scheduler for tasks since the game is ...
5
votes
2answers
709 views
ForEachAsync extension method (a way to run an async operation on each item of a sequence in parallel)
In a recent project I worked on we faced some issues due to an excess of parallelization (thousands of threads were created and the overall result was a degradation of performance and several spikes ...
3
votes
1answer
85 views
FutureTaskWrapper for Java
I did not like that get synchronizes every time I call it - because I may be calling it more than once. So I wrote the wrapper for the future interface which keeps ...
0
votes
1answer
72 views
Reading lines from a file and processing them concurrently
I'd like to read lines from a file and process them concurrently. I came up with the following code to do this:
...
0
votes
0answers
21 views
Processing object writes to external datastore in parallel using ForkJoinPool and list streams
I have the following code. I wanted to see if you thought this was a good way to go about processing an array of objects in parallel using a ForkJoinPool and array streams. This is just a sample, in ...
1
vote
0answers
114 views
Concurrent hash map implementation with Go's channels
I've implemented a concurrent hash map in Go. I'm fairly new to this language as I have mostly Python background so I'm looking for suggestions how to improve my code. I've ran the tests with ...
4
votes
2answers
86 views
Semaphore skipping additional threads
In this example I've a refresh method that might be called by multiple threads. Requirements are:
refresh() method must be processed by only one thread at a time (...
3
votes
1answer
64 views
Java Concurrent Recursive API Access
I don't get to write multithreaded applications very often, so be gentle with my threads :-)
I have an API input which contains a "score" and then a bunch of child nodes which also have scores, and ...
0
votes
0answers
32 views
Thread safe tile grid abstraction and implementation
I'm working on a tile engine and I'm trying to write a nice abstraction for writing Tiles and TileImages (which are just a group ...
4
votes
0answers
57 views
Drawing the Mandelbrot with multiple threads in rust
The code below draws the mandelbrot set for { z | z∈ ℂ, -2.2 ≤ Re(z) ≤ 0.6, -1.4 ≤ Im(z) ≤ 1.4} into a 300×300px png image. For each pixel,
if the sequence {zi} is found to ...
3
votes
1answer
86 views
HTTP Load test with Golang
I am a golang novice... I am trying to write an application that takes in many requests - up to a sustained 10000 HTTP posts/sec and post the payload to two back-ends in parallel (5 second timeout). ...
1
vote
0answers
17 views
JSON API Scraper v2: Limited concurrency AJAX from a shared queue (ES2017)
Essentially the AJAX component of this question, reimplemented in ES2017 style async/await. The code connects to a remote JSON API and scrapes it using a limited number of streams to avoid triggering ...
2
votes
1answer
86 views
Concurrent access to data with QReadWriteLock
Using Qt, I've got this code in order to protect access to some shared data between threads. I'm pretty sure the idea is correct, but I don't know if RVO and/or RAII could potentially screw the ...
1
vote
1answer
287 views
Concurrent fire and forget async task queue
I had to do a lot of IO stuff on my server running Node JS where I did not really care about the result of the operations. The list of incoming tasks could be huge, so I had to limit the number of ...
4
votes
0answers
176 views
An in-memory copy of the GDAX order book for an arbitrary cryptocurrency, updated in real time
GDAX is the cryptocurrency exchange owned and operated by Coinbase.
This code is intended to be the basis for an order-book-strategy trading bot.
I'd love feedback on my use of data structures, my ...
