warrentyexpired/ModernUO
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

last of the non generics for custom houses

Browse source
This commit is contained in:
mark 2006-12-29 04:37:28 +00:00
parent 455fa28f48
commit 1df688e912
1 changed files with 19 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

24
Scripts/Multis/HouseFoundation.cs
View file

@ -2379,13 +2379,15 @@ namespace Server.Multis
}
}
private static Queue m_SendQueue;
private static Queue<SendQueueEntry> m_SendQueue;
private static object m_SendQueueSyncRoot;
private static AutoResetEvent m_Sync;
private static Thread m_Thread;
static DesignStateDetailed()
{
m_SendQueue = Queue.Synchronized( new Queue() );
m_SendQueue = new Queue<SendQueueEntry>();
m_SendQueueSyncRoot = ((ICollection)m_SendQueue).SyncRoot;
m_Sync = new AutoResetEvent( false );
m_Thread = new Thread( new ThreadStart( CompressionThread ) );
@ -2399,9 +2401,15 @@ namespace Server.Multis
{
m_Sync.WaitOne();
while( m_SendQueue.Count > 0 )
int count;
lock ( m_SendQueueSyncRoot )
count = m_SendQueue.Count;
while( count > 0 )
{
SendQueueEntry sqe = (SendQueueEntry)m_SendQueue.Dequeue();
lock ( m_SendQueueSyncRoot )
SendQueueEntry sqe = m_SendQueue.Dequeue();
try
{
@ -2437,6 +2445,11 @@ namespace Server.Multis
{
}
}
finally
{
lock ( m_SendQueueSyncRoot )
count = m_SendQueue.Count;
}
//sqe.m_NetState.Send( new DesignStateDetailed( sqe.m_Serial, sqe.m_Revision, sqe.m_xMin, sqe.m_yMin, sqe.m_xMax, sqe.m_yMax, sqe.m_Tiles ) );
}
@ -2454,7 +2467,8 @@ namespace Server.Multis
public static void SendDetails( NetState ns, HouseFoundation house, DesignState state )
{
m_SendQueue.Enqueue( new SendQueueEntry( ns, house, state ) );
lock ( m_SendQueueSyncRoot )
m_SendQueue.Enqueue( new SendQueueEntry( ns, house, state ) );
m_Sync.Set();
}
}