66 lines
1.7 KiB
C#
66 lines
1.7 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Net.Sockets;
|
|
using System.Text;
|
|
using System.Threading;
|
|
|
|
namespace Kneesocks {
|
|
public class Stack<T> where T : Connection {
|
|
private Pool<T> PoolRef = null;
|
|
private List<Connection> Clients = new List<Connection>();
|
|
private Mutex ClientsMutex = new Mutex();
|
|
private bool RunWithNoClients = false;
|
|
private bool Running = true;
|
|
private bool _finished = false;
|
|
|
|
public Stack(Pool<T> poolRef, Connection initialConnection = null) {
|
|
PoolRef = poolRef;
|
|
if(initialConnection != null)
|
|
Clients.Add(initialConnection);
|
|
}
|
|
|
|
public Stack(Pool<T> poolRef, bool runWithNoClients, Connection initialConnection = null)
|
|
: this(poolRef, initialConnection)
|
|
{
|
|
RunWithNoClients = runWithNoClients;
|
|
}
|
|
|
|
public bool AddClient(Connection client) {
|
|
if(!ClientsMutex.WaitOne(5000))
|
|
return false;
|
|
|
|
Clients.Add(client);
|
|
|
|
ClientsMutex.ReleaseMutex();
|
|
return true;
|
|
}
|
|
|
|
public int Count {
|
|
get {
|
|
return Clients.Count;
|
|
}
|
|
}
|
|
|
|
public void StopThread() {
|
|
Running = false;
|
|
}
|
|
|
|
public bool Finished { get; private set; }
|
|
|
|
// USED FOR THREADING -- DO NOT CALL
|
|
public void ManageStack() {
|
|
while(Running && (Count > 0 || RunWithNoClients)) {
|
|
for(var i = Count - 1; i >= 0 && Running; ++i) {
|
|
Clients[i].OnParse();
|
|
|
|
|
|
}
|
|
}
|
|
|
|
Finished = true;
|
|
PoolRef.InvalidateThread(this);
|
|
}
|
|
}
|
|
}
|