101 lines
3.5 KiB
C#
101 lines
3.5 KiB
C#
using System;
|
|
using System.Threading;
|
|
|
|
namespace DepthFirstScheduler
|
|
{
|
|
public static partial class Scheduler
|
|
{
|
|
private static IScheduler singleWorkerThread;
|
|
|
|
public static IScheduler SingleWorkerThread
|
|
{
|
|
get { return singleWorkerThread ?? (singleWorkerThread = new ThreadScheduler()); }
|
|
}
|
|
|
|
public class ThreadScheduler : IScheduler
|
|
{
|
|
MonitorQueue<TaskChain> m_queue = new MonitorQueue<TaskChain>();
|
|
|
|
Thread m_thread;
|
|
|
|
public ThreadScheduler()
|
|
{
|
|
// start worker thread
|
|
m_thread = new Thread(new ParameterizedThreadStart(Worker));
|
|
m_thread.Start(m_queue);
|
|
}
|
|
|
|
static void Worker(Object arg)
|
|
{
|
|
MonitorQueue<TaskChain> queue = (MonitorQueue<TaskChain>)arg;
|
|
while (true)
|
|
{
|
|
var chain = queue.Dequeue();
|
|
if (chain == null)
|
|
{
|
|
break;
|
|
}
|
|
|
|
while (true)
|
|
{
|
|
var status = chain.Next();
|
|
if (status != ExecutionStatus.Continue)
|
|
{
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
// end
|
|
}
|
|
|
|
public void Enqueue(TaskChain item)
|
|
{
|
|
m_queue.Enqueue(item);
|
|
}
|
|
|
|
#region IDisposable Support
|
|
|
|
private bool disposedValue = false; // 重複する呼び出しを検出するには
|
|
|
|
protected virtual void Dispose(bool disposing)
|
|
{
|
|
if (!disposedValue)
|
|
{
|
|
if (disposing)
|
|
{
|
|
// TODO: マネージ状態を破棄します (マネージ オブジェクト)。
|
|
if (m_thread != null)
|
|
{
|
|
m_queue.Enqueue(null);
|
|
m_thread.Join();
|
|
m_thread = null;
|
|
}
|
|
}
|
|
|
|
// TODO: アンマネージ リソース (アンマネージ オブジェクト) を解放し、下のファイナライザーをオーバーライドします。
|
|
// TODO: 大きなフィールドを null に設定します。
|
|
|
|
disposedValue = true;
|
|
}
|
|
}
|
|
|
|
// TODO: 上の Dispose(bool disposing) にアンマネージ リソースを解放するコードが含まれる場合にのみ、ファイナライザーをオーバーライドします。
|
|
// ~ThreadScheduler() {
|
|
// // このコードを変更しないでください。クリーンアップ コードを上の Dispose(bool disposing) に記述します。
|
|
// Dispose(false);
|
|
// }
|
|
|
|
// このコードは、破棄可能なパターンを正しく実装できるように追加されました。
|
|
public void Dispose()
|
|
{
|
|
// このコードを変更しないでください。クリーンアップ コードを上の Dispose(bool disposing) に記述します。
|
|
Dispose(true);
|
|
// TODO: 上のファイナライザーがオーバーライドされる場合は、次の行のコメントを解除してください。
|
|
// GC.SuppressFinalize(this);
|
|
}
|
|
|
|
#endregion
|
|
}
|
|
}
|
|
}
|