Questions tagged [queue]
A queue is an ordered, first-in-first-out (FIFO) data structure. Typical implementations of queues support pushing elements to the back and popping them off the front position.
41
questions with no upvoted or accepted answers
5
votes
0
answers
180
views
Concurrent Queue using Ada SPARK with the Ravenscar profile
See here: https://gitlab.com/linted/linted/blob/162b5e9fba53a90b3c6d78e214776e069c3c722b/src/ada-core/src/linted-queues.adb
The code implements a concurrent queue.
It can't allocate memory or use ...
- 268
4
votes
0
answers
446
views
Queue with "unlimited" buffer in Go
This is small piece of bigger puzzle, but usable by its own.
It an attempt to have a nonblocking queue with "unlimited" (besides memory size) buffer length.
Got unit-tests 100% statement coverage, it ...
- 211
3
votes
0
answers
354
views
Async FIFO processing of database writes - naive implementation in .Net 6
One of the companies I was recently interviewing with gave me a following task to implement in a day or two using .Net, just to see where my coding abilities are at:
Implement a Web API that gets ...
- 31
3
votes
0
answers
2k
views
File-system based queue in python
I would like to implement a concurrent (multi-thread, multi-process) queue that is backed by file system. Data is pickled over a file, stored in a directory and given a sequential name.
The ...
3
votes
0
answers
189
views
Templatized GLib asynchronous queue
I'm working on a legacy C++ project, which is using GLib for its Main Event Loop. This has caused a lot of ugliness because it mixes C++ and C paradigms (no C++ wrapper for GLib had been used).
...
- 141
3
votes
0
answers
569
views
Blocking Promise-driven queues with ECMAScript's async/await and generators
I implemented an AsyncQueue, whose dequeue() operation returns a Promise. The ...
- 751
3
votes
0
answers
59
views
Python simulacrum of windows copy window
I wrote a program to copy files with an progress bar that looks similar to Windows built in function. The copy function is run in a separate thread and the tkinter GUI is run in the main thread. This ...
- 31
3
votes
0
answers
3k
views
Checking number of messages in jms queue code
I need to check number of messages in a jms queue for that i am using queuebrowser.
Actually i have 2 queues. I check if there are more then 10 messages in second queue then the first queue should not ...
- 163
3
votes
0
answers
524
views
Immutable queue implementation in Scala
I created a queue in which we can perform Enqueue, Dequeue and Traversing in Scala.
...
3
votes
0
answers
551
views
Multithreaded queue manager
I've written a simple multithreaded queue manager in JavaScript which will be seeing some pretty heavy usage at a later point in the project I'm working on. I think it's pretty solid, but I wouldn't ...
2
votes
0
answers
534
views
Multi-producer/single-consumer queue in Python
I am currently working on a problem that involves multiple producers and a single consumer through a queue object. The following list is about a few things that's special about this problem:
One ...
- 327
2
votes
0
answers
212
views
Fixed-width non-FIFO DispatchQueue
I have implemented a custom concurrent queue on top of GCD which offers two additional pieces of functionality:
Limit the maximum number of concurrently executing tasks.
Give manual control over ...
- 121
2
votes
0
answers
599
views
MongoQ - A Task queue system using Mongo
I've been using Beanstaldk (not Amazon's one) for years and loved the possibility to handle delays and priorities in the tasks, but I recently had to filters the tasks for specific reasons, and ...
- 245
2
votes
0
answers
86
views
Lock-free pooled queue
I am attempting to create a lock free pool of resources and I need the ability to access any one that is not already accessed and then return it back when I do not need it. This will happen very very ...
2
votes
0
answers
431
views
thread safe queue with interrupt function
I try to implement a thread safe queue with the interrupt function (interrupt all threads who are blocking to take data from queue).
...
- 21
2
votes
0
answers
256
views
Throttle submissions to ExecutorService
To prevent an XY problem, I'll first explain the problem I am trying to solve:
Problem I am trying to solve
I want to send the contents of a MongoDB collection with a size of around
3 million ...
2
votes
0
answers
565
views
Producer Consumer Using TPL Dataflow
I have written the following class which is supposed to act as a consumer of messages that are passed in from producers and forward them onto amazon SQS, I have made a compromise by starting the ...
- 349
2
votes
0
answers
271
views
Request Queue for League of Legends API
I am working on some website for League of Legends statistics, which uses the RiotGames API.
The API allows you to do a maximum amount of requests per 10 seconds, and another maximum amount of ...
- 121
2
votes
0
answers
93
views
Blocking Memory Queue
This is a FIFO blocking memory queue in F# to be used as a component in a logging library.
...
2
votes
0
answers
51
views
Functional, Loaner-Like Pattern For Consuming SQS Queues, Deleting Queue Items On Success
My program fetches input from a RabbitMQ or Amazaon SQS-like queue. There is not always input available in the queue. If a message is available, it triggers work. If that work is successful, ...
2
votes
0
answers
517
views
WebApi synchronize database (EF 6) access
I'm working on an ASP.Net MVC 5/WebApi 2 project. I'm using EF 6 code first for my database access.
I have a WebApi action method in which I've to update some data in my database based on the request....
- 292
1
vote
1
answer
82
views
Queue-mergesort: a mergesort that does optimal number of comparisons in the worst case in Java
Here is the code for queue-mergesort by Mordecai J. Golin and Robert Sedgewick:
com.github.coderodde.util.QueueMergesort.java:
...
- 26.7k
1
vote
0
answers
1k
views
Node.js batch processing
Batch processing steps:
When a job is posted, push it to the queue.
Get the required number of items from the queue and put it in the ...
- 370
1
vote
1
answer
288
views
Optimize Leetcode 239. Sliding Window Maximum using Swift
LeetCode problem 239. Sliding Window Maximum
You are given an array of integers nums,
there is a sliding window of size k which ...
- 223
1
vote
0
answers
105
views
Breadth first search of a binary-tree with channels
As an exercise in using channels in Go I implemented a breadth-first traversal of a binary tree, using a channel as a queue to store the order of the nodes to traverse. After ironing out a bunch of ...
- 111
1
vote
0
answers
49
views
Implementing a Queue with Small size optimization
I was trying to implement a queue implementing the small size optimization. I was wondering any ways I can make this code better (more performant, better code style, etc). It seems to work fine (in ...
- 11
1
vote
0
answers
48
views
Run non overlapped periodical tasks on user specified executor
I have concurrency tasks in my module: user code is able to instantiate my object and specify Executor service, then user can submit requests to this object which ...
- 111
1
vote
0
answers
33
views
regex on a log file utilizing stacks and queue's in Java
This would be for a MUD client, which has elements of a sort of telnet bot.
Here, there's ...
- 379
1
vote
0
answers
172
views
Codewars Kata - Tickets Queue
The challenge:
You managed to send your friend to queue for tickets in your stead, but there is a catch: he will get there only if you tell him how much that is going to take. And everybody can ...
- 127
1
vote
0
answers
67
views
Puzzling SBCL Compiler Note
I’m having trouble understanding an SBCL compiler note about unreachable code in the following function. The referenced code is attempting to push a value into an Lparallel queue: ...
- 415
1
vote
0
answers
124
views
Immutable Queue with Bulk-Enqueue
I recently needed a data structure with FIFO queue semantics that supported efficient bulk-insertion (often need to enqueue thousands of messages at once). I took a look at Purely Functional Data ...
- 571
1
vote
0
answers
121
views
thread safe queue with watermarks
A thread-safe queue suspending/resuming the producer when respectively upper/lower watermark has been crossed. Intended usage - interchange between a non-blocking IO loop thread and a consumer running ...
- 361
1
vote
0
answers
691
views
Continuous queue with delay support
I'm new to programming in Python, and I have a task to try and create continuous queue but with delay support. I need to use this for a messaging queue and simulate network latency at different rates ...
- 11
1
vote
0
answers
856
views
Socket server with consumer-producer design to handle concurrent connections
The usual way is to implement socket server to handle concurrent requests by creating new thread for each request.
Instead of this approach i tried to create a server using ...
- 257
1
vote
0
answers
1k
views
Load balancing consumer and producer with multiprocessing
Tasks are distributed to producer in multiple worker process. Results from workers are sent through Queue to a ...
1
vote
0
answers
2k
views
Array based Queue Implementation using Templates
This is my first code using templates and I wanted to know if the code looks good?
I have some doubts like what's the best way to report error to user (queue full/empty), I checked a link online http:...
- 61
1
vote
0
answers
107
views
Implementation of Dequeue data structure
I have just started learning to code for interviews and I would like to request a code review of a "Dequeue" data structure. I could not find any implementation anywhere to compare it to. I would like ...
- 11
1
vote
0
answers
63
views
Counting dropped frames while converting uncompressed video data
I am writing a class for converting uncompressed video data which processes data in its incoming queue and stores them in its outgoing queue. Every time it tries to process a frame of a format it ...
- 313
1
vote
0
answers
340
views
Queue that permits at most X simultaneous operations
I ran into this once (permits=N) and then again today (permits =1) where I only want 1 to N operations running simultaneously. One example comes from firing into a state machine (the permit=1 example)...
- 111
0
votes
0
answers
45
views
Sending events to the API via queue functionality
I am working on the queue which requirements are:
We can 3 types of events (start, heartbeat which will be added to the queue in 5sec intervals, and the end event)
Backup the events in local storage ...
- 163
0
votes
0
answers
197
views
ASP.NET Core 6 background DB logger
In an application, many actions need to be logged in the database. but this logging process should not slow down the request. So they should be done in an asynchronous queue or something.
This is my ...
- 1