BackgroundFetcher.cs

using System;
using System.Threading;
using Common;

namespace Server
{
        public class BackgroundFetcher  {
                MCP masterControl; 
                HTTPObjectQueue fetchQueue;
                Thread processingThread;

                public BackgroundFetcher(MCP masterControl)     {
                        this.masterControl = masterControl;
                        fetchQueue = new HTTPObjectQueue();
                        processingThread = new Thread(new ThreadStart(run));
                }

                public void AddToFetchQueue(HTTPRequestQueueObject request) {
                        fetchQueue.EnqueueBlocking(request);
                }

                public void Start() {
                        processingThread.Start();
                }

                public void Stop() {
                        processingThread.Abort();
                }

                void run() {
                        try {
                                while(true) {
                                        HTTPRequestQueueObject request = (HTTPRequestQueueObject)fetchQueue.DequeueBlocking();
                                        Console.WriteLine("- Background fetching {0}", request.URI);
                                        HTTPResponse response = masterControl.ServiceHTTPRequest(request);
                                        masterControl.SendResponse(response, request, true);
                                        Thread.Sleep(10);
                                }
                        } catch (ThreadAbortException) {
                                Console.WriteLine("[Background Fetcher shut down]");
                        }
                }
        }
}

---