在 C# 中使用布尔标志来停止线程运行是否安全?

问题描述 投票:0回答:4

我主要关心的是布尔标志......在没有任何同步的情况下使用它是否安全?我在几个地方读到它是原子的(包括文档)。

class MyTask
{
    private ManualResetEvent startSignal;
    private CountDownLatch latch;
    private bool running;

    MyTask(CountDownLatch latch)
    {
        running = false;
        this.latch = latch;
        startSignal = new ManualResetEvent(false);
    }

    // A method which runs in a thread
    public void Run()
    {
        startSignal.WaitOne();
        while(running)
        {
            startSignal.WaitOne();
            //... some code
        }
        latch.Signal();
    }

    public void Stop()
    {
        running = false;
        startSignal.Set();
    }

    public void Start()
    {
        running = true;
        startSignal.Set();
    }

    public void Pause()
    {
        startSignal.Reset();
    }

    public void Resume()
    {
        startSignal.Set();
    }
}

以这种方式设计任务是否安全?有什么建议、改进、意见吗?

注意:我编写了我的自定义

CountDownLatch
类,以防您想知道我从哪里得到它。

更新:
这也是我的 CountDownLatch:

public class CountDownLatch 
{
    private volatile int m_remain;
    private EventWaitHandle m_event;

    public CountDownLatch (int count)
    {
        if (count < 0)
            throw new ArgumentOutOfRangeException();
        m_remain = count;
        m_event = new ManualResetEvent(false);
        if (m_remain == 0)
        {
            m_event.Set();
        }
    }

    public void Signal()
    {
        // The last thread to signal also sets the event.
        if (Interlocked.Decrement(ref m_remain) == 0)
            m_event.Set();
    }

    public void Wait()
    {
        m_event.WaitOne();
    }
}
c# multithreading thread-safety
4个回答
49
投票

你最好标记它

volatile

volatile 关键字表示 字段可能被多个修改 并发执行线程。领域 声明为 挥发性 的不是 受编译器优化的影响 假设由单线程访问。这 确保最新的值 始终在现场。

但我会改变你的循环:

    startSignal.WaitOne();
    while(running)
    {
        //... some code
        startSignal.WaitOne();
    }

正如您的帖子中所述,当线程停止(即调用 Stop 时)时,“某些代码”可能会执行,这是意外的,甚至可能是不正确的。


6
投票

布尔值在 C# 中是原子的,但是,如果你想在一个线程中修改它并在另一个线程中读取它,你至少需要将其标记为 volatile。 否则读取线程实际上可能只会将其读入寄存器一次。


2
投票

0
投票

顺便说一句,我刚刚注意到这部分代码:

// A method which runs in a thread
    public void Run()
    {
        startSignal.WaitOne();
        while(running)
        {
            startSignal.WaitOne();
            //... some code
        }
        latch.Signal();
    }

您需要使用“startSignal.Set()”解锁工作线程两次,以便执行 while 块中的代码。

这是故意的吗?

© www.soinside.com 2019 - 2024. All rights reserved.