64 lines
1.5 KiB
C#
64 lines
1.5 KiB
C#
////////////////////////////////////////////////////////////////////////////////
|
|
//
|
|
// Microsoft Research Singularity
|
|
//
|
|
// Copyright (c) Microsoft Corporation. All rights reserved.
|
|
//
|
|
// File: ServiceThread.cs
|
|
//
|
|
// Note:
|
|
//
|
|
|
|
using System.Threading;
|
|
using System.Runtime.CompilerServices;
|
|
|
|
namespace Microsoft.Singularity
|
|
{
|
|
///
|
|
/// <summary>
|
|
/// Class processing asynchronous requeusts
|
|
/// </summary>
|
|
///
|
|
public class ServiceThread
|
|
{
|
|
internal static void Initialize()
|
|
{
|
|
queue = new ServiceRequestQueue();
|
|
Thread.CreateThread(Thread.CurrentProcess, new ThreadStart(ServiceLoop)).Start();
|
|
}
|
|
|
|
///
|
|
/// <summary>
|
|
/// Enqueue a request into the service queue
|
|
/// </summary>
|
|
///
|
|
/// <param name="req">Requeuest to enqueu</param>
|
|
///
|
|
[NoHeapAllocation]
|
|
internal static void Request(ServiceRequest req)
|
|
{
|
|
// Dequeue the request
|
|
queue.Enqueue(req);
|
|
}
|
|
|
|
///
|
|
/// <summary>
|
|
/// Service thread loop processing requests
|
|
/// </summary>
|
|
///
|
|
private static void ServiceLoop()
|
|
{
|
|
while (true) {
|
|
|
|
ServiceRequest req = queue.Dequeue();
|
|
|
|
req.Service();
|
|
}
|
|
}
|
|
|
|
/// <summary> Service queue </summary>
|
|
private static ServiceRequestQueue queue;
|
|
|
|
}
|
|
}
|