如何在线程正在工作时停止服务(不使用Thread.Abort)

Question

我有一个服务在循环中运行一些不同的任务,直到服务停止.但是,我调用Web服务和此调用的其中一个任务可能需要几分钟才能完成.我希望能够立即停止服务,"取消"Web服务调用而不调用,Thread.Abort因为这会导致一些奇怪的行为,即使线程正在做的唯一事情是调用此Web服务方法.

如何取消或中断同步方法调用(如果可能的话)？或者我应该尝试不同的方法？

我试图使用AutoResetEvent,然后调用Thread.Abort哪个在下面的代码示例中正常工作,但是当在实际服务中实现此解决方案时,我得到一些意外的行为,可能是因为我正在使用的外部库中发生了什么.

AutoResetEvent并且Thread.Abort:

class Program
{
    static void Main(string[] args)
    {
        MainProgram p = new MainProgram();
        p.Start();
        var key = Console.ReadKey();
        if (key.Key == ConsoleKey.Q)
            p.Stop();
    }
}

class MainProgram
{
    private Thread workerThread;
    private Thread webServiceCallerThread;
    private volatile bool doWork;

    public void Start()
    {
        workerThread = new Thread(() => DoWork());
        doWork = true;
        workerThread.Start();
    }

    public void Stop()
    {
        doWork = false;
        webServiceCallerThread.Abort();
    }

    private void DoWork()
    {
        try
        {
            while (doWork)
            {
                AutoResetEvent are = new AutoResetEvent(false);
                WebServiceCaller caller = new WebServiceCaller(are);
                webServiceCallerThread = new Thread(() => caller.TimeConsumingMethod());
                webServiceCallerThread.Start();

                // Wait for the WebServiceCaller.TimeConsumingMethod to finish
                WaitHandle.WaitAll(new[] { are });

                // If doWork has been signalled to stop
                if (!doWork)
                    break;

                // All good - continue
                Console.WriteLine(caller.Result);
            }
        }
        catch (Exception e)
        {
            Console.Write(e);
        }
    }
}

class WebServiceCaller
{
    private AutoResetEvent ev;
    private int result;

    public int Result
    {
        get { return result; }
    }

    public WebServiceCaller(AutoResetEvent ev)
    {
        this.ev = ev;
    }

    public void TimeConsumingMethod()
    {
        try
        {
            // Simulates a method running for 1 minute
            Thread.Sleep(60000);
            result = 1;
            ev.Set();
        }
        catch (ThreadAbortException e)
        {
            ev.Set();
            result = -1;
            Console.WriteLine(e);
        }
    }
}

有人可以建议解决这个问题吗？

Answer 1

试试这个

public void Start()
{
    workerThread = new Thread(() => DoWork());
    doWork = true;
    workerThread.IsBackground = true;
    workerThread.Start();
}

线程是后台线程或前台线程.后台线程与前台线程相同,除了后台线程不会阻止进程终止.一旦属于进程的所有前台线程终止,公共语言运行库就结束该进程.任何剩余的后台线程都会停止并且不会完成.

有关更多详细信息,请参阅http://msdn.microsoft.com/en-us/library/system.threading.thread.isbackground.aspx