11,242 questions
1
vote
1
answer
98
views
Sometimes wrong output in Java queue simulation
Problem summary:
Each person in line has tickets[i] tickets to buy. Every second
The person at the front buys one ticket.
If they still need more tickets, they move to the end of the queue.
We need ...
- 11
0
votes
0
answers
91
views
Laravel Queue Process Slow
I hope you’re all doing well. I’m reaching out because I’m facing an issue with my setup. I have a .NET application and a Laravel system integrated via API. The .NET application sends payloads to the ...
1
vote
1
answer
45
views
Is circular linked list needed for "Circular" queue?/
I am learning about queue data structure in python. I learnt the implementation of a queue using list in python and the issue of memory wastage when we dequeue a few elements from the front. We use a ...
- 53
2
votes
0
answers
119
views
Why does my queued job in Laravel 10 not execute after dispatch?
I have a fresh Laravel 10 app and I'm trying to test queues.
I created a job with php artisan make:job TestJob.
routes/web.php
Route::get('/test-job', function () {
\App\Jobs\TestJob::dispatch();
...
3
votes
1
answer
73
views
Celery task called inside another task always goes to default queue even with queue specified
I’m running Celery with Django and Celery Beat.
Celery Beat triggers an outer task every 30 minutes, and inside that task I enqueue another task per item.
Both tasks are decorated to use the same ...
- 60
0
votes
0
answers
53
views
ASP.NET Core background service and queue processing behaves weird
I have a background service that periodically reads (not peeks) a message from an Azure storage queue and call an API to get values (that could returns 204 and will be retired), and then once gets ...
- 391
2
votes
1
answer
141
views
This MPSC Queue (Multi Producer Single Consumer Queue) keeps on waiting in the consumer side sometimes although I have used CAS operations
This MPSC Queue (Multi Producer Single Consumer Queue) keeps on waiting in the consumer side sometimes although I have used CAS operations. I have added CAS operation for the enqueue function. Since I ...
-1
votes
2
answers
170
views
How do i comunicate between Threads Using Queues(janus)?? In Python [closed]
I'm building a multi-threaded system where:
One thread connects to a WebSocket, processes live kline data, and
queues symbol-interval keys for processing.
Another thread runs multiple async workers ...
- 1
0
votes
4
answers
173
views
is there a way to empty a queue in O(1)?
I'm trying to understand the time complexities associated with standard data structures. For a queue, we know that enqueue() and dequeue() operations are typically O(1) in implementations like using a ...
1
vote
1
answer
157
views
How to consume a Cloudflare Queue with NuxtHub (version 0.8.25)?
I'm working on a Nuxt project that uses NuxtHub and Cloudflare Queues.
✅ I can successfully publish messages to the queue like this:
const { cloudflare } = event.context;
console.log("Publishing ...
2
votes
1
answer
75
views
Python multiprocessing.Queue strange behaviour
Hi I'm observing a strange behaviour with python multiprocessing Queue object.
My environment:
OS: Windows 10
python: 3.13.1
but I observed the same with:
OS: Windows 10
python: 3.12.7
and:
OS: ...
- 650
0
votes
2
answers
96
views
Python Multiprocessing Pool Queue Works in Functional Code but not in OOP
I am learning multiprocessing in Python and am trying to incorporate a worker pool for managing downloads. I have deduced my queue issue down to something with OOP, but I don't know what it is. The ...
0
votes
1
answer
61
views
Items getting dropped while adding a list to queue
I have a system where I am trying to achieve a single point of action for writing to a database. For this I am using Queues, I fetch a record from a queue and add to a list. Once I have a required ...
- 25
1
vote
1
answer
133
views
How to run Laravel queue on the production server? [closed]
I have used the queue job in my Laravel project to send emails to multiple users. My code is working perfectly on the local system, but on the production server, when I run the queue:work command, it ...
- 11
0
votes
1
answer
60
views
Deadlock in Multiprocessing Queue
I am developing a program to simulate a P2P network using the multiprocessing package. Specifically, I have created a Node class that inherits from multiprocessing.Process and contains all the basic ...
- 529
1
vote
0
answers
140
views
c# NATS auth callout Authentication
I want to implement out callout authentication on NATS. I have created a console application that listens to the $SYS.REQ.USER.AUTH topic. Based on the received username and password, I generate a JWT ...
- 35
0
votes
1
answer
78
views
queue does not detect database connection changes in laravel octane
Laravel ^11.0
Octane ^2.2
Server FrankenPHP
RabbitMQ
I have a backend using laravel octane, then I change the database connection ip. To get the new database data it has been detected. However, I ...
-1
votes
1
answer
125
views
Lock on a Resource queue to ensure only one container access the Resource
I am planning to develop a Java application and deploy it in K8s containers where the minimum containers are 3.
My requirement is to maintain a common queue for the 3+ containers and run a scheduler ...
- 10.7k
1
vote
1
answer
80
views
What are the drawbacks of implementing dequeue using procedure int? [closed]
I'm trying to implement a queue and for dequeue I've purposely done with an int procedure. What would be possible drawbacks for using an int?
int dequeue(queue *q) {
int res = 0; // list not empty
...
- 21
1
vote
0
answers
25
views
Livelock in tantrum Queues
I'm studying lock free MPMC queues, and I read some papers mainly about common practices and/or designs. I found myself reading about tantrum queues, that are lock free data structures that emulate an ...
- 84
0
votes
1
answer
87
views
How to Reactively read a Queue with Dynamic Delay using Mutiny in Java?
Currently I have a service which read events from a queue in SQS and process the found messages. I have a concurrency with 2 threads reading at the same time the queue to process the messages. The ...
- 545
1
vote
1
answer
41
views
'IterQueue' object has no attribute 'not_full'
I have a class called "IterQueue which is an iter queue:
IterQueue.py
from multiprocessing import Process, Queue, Pool
import queue
class IterQueue(queue.Queue):
def __init__(self):
self....
- 579
0
votes
0
answers
207
views
BullMQ Job Not Removed from Queue After Calling job.remove()
I’m prototyping a project using BullMQ and Redis, and so far, everything seems to be working fine. Jobs are being added to the queue successfully. However, when I process the jobs using a worker and ...
- 170
0
votes
1
answer
56
views
In laravel how do I ran a job on one queue only?
I have an app in vapor and I have a long running job lets say UpdateSomething and I want this job to be on one queue only, I don't want it to run concurrently.
class UpdateSomething implements ...
- 4,586
0
votes
0
answers
25
views
How can I pass an AbstractQueryFilter or its filters to a Job in Laravel without encountering the 'Serialization of 'Closure' is not allowed' error?
I’m using Ambengers\QueryFilter\AbstractQueryFilter (Git Repository) in a project. I need to perform a database search and generate a PDF of student logs, but I want to handle this with a job. When I ...
