deavmi/tristanable
deavmi
/
tristanable
mirror of https://github.com/deavmi/tristanable.git
1
0
Fork 0
Code Issues 2 Projects Releases Wiki Activity

Use DList

This commit is contained in:
Tristan B. Velloza Kildaire 2021-09-08 11:14:03 +02:00
parent 916bfec075
commit 5f16e8d5b0
2 changed files with 20 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
source/tristanable/manager.d
View File

@ -5,11 +5,12 @@ import core.sync.mutex : Mutex;
import bmessage : bSendMessage = sendMessage;
import tristanable.queue : Queue;
import tristanable.watcher;
import std.container.dlist;
public final class Manager
{
/* All queues */
private Queue[] queues;
private DList!(Queue) queues;
private Mutex queuesLock;
/* TODO Add drop queue? */

34
source/tristanable/queue.d
View File

@ -15,6 +15,7 @@ import std.socket : Socket;
import core.sync.mutex : Mutex;
import bmessage : bSendMessage = sendMessage;
import core.thread : Thread;
import std.container.dlist;
public final class Queue
{
@ -22,7 +23,7 @@ public final class Queue
private ulong tag;
/* The queue */
private QueueItem[] queue;
private DList!(QueueItem) queue;
/* The queue mutex */
private Mutex queueLock;
@ -66,13 +67,14 @@ public final class Queue
queueLock.lock();
/* Check if we can dequeue anything */
if(queue.length)
if(!queue.empty())
{
/* If we can then dequeue */
queueHead = queue[0];
queueHead = queue.front();
queue.removeFront();
/* Chop off the head */
offWithTheHead();
// offWithTheHead();
}
/* Unlock the queue */
@ -102,20 +104,20 @@ public final class Queue
* Not thread safe but only called by thread
* safe (mutex locking) method
*/
private void offWithTheHead()
{
/* The new queue */
QueueItem[] newQueue;
// private void offWithTheHead()
// {
// /* The new queue */
// QueueItem[] newQueue;
/* Add everything but the first */
for(ulong i = 1; i < queue.length; i++)
{
newQueue ~= queue[i];
}
// /* Add everything but the first */
// for(ulong i = 1; i < queue.length; i++)
// {
// newQueue ~= queue[i];
// }
/* Make the the new queue */
queue = newQueue;
}
// /* Make the the new queue */
// queue = newQueue;
// }
/**
* Returns the tag for this queue