Question

我有一个多行应用程序。我只需要一条线来执行我的函数和其他线索来通过它。我执行我的函数时, 我该怎么做呢?

我的方法有点像:

    public void setOutput(int value)
    {
        try
        {
            GPOs gpos = reader.Config.GPO;
            gpos[1].PortState = GPOs.GPO_PORT_STATE.TRUE;
            gpos[2].PortState = GPOs.GPO_PORT_STATE.TRUE;
            Thread.Sleep(WAIT);
            gpos[1].PortState = GPOs.GPO_PORT_STATE.FALSE;
            gpos[2].PortState = GPOs.GPO_PORT_STATE.FALSE;
        }
        catch (Exception ex)
        {
            logger.Error("An Exception occure while setting GPO to " + value + " " + ex.Message);
        }
    }

Answer 1

您可以与“http://msdn.microsoft.com/en-us/library/system.threading.monitor.monitor.tryenter.aspx” rel=“noreferrer”\ code>Monitor.TryEnter 一起使用锁定对象。

private Object outputLock = new Object();

public void setOutput(int value)
{
    if Monitor.TryEnter(outputLock)
    {
        try
        {
            .... your code in here
        }
        finally
        {
            Monitor.Exit(outputLock);
        }
    }
}

只有一条时间线可以进入 Monitor.TryEnter 块。如果一条线到达这里, 而另一条线在其中, 那么 Monitor.TryEnter 返回 false 。

Answer 2

您可以使用 < a href=" "http://msdn. microsoft.com/query/ dev10.query? appId= Dev10IDEF1 & amp; l= EN- US& k=k% 28SYSTEM.Treadding. MUTEX% 29; k% 28MUTEX%29; k% 28MUTEX% 29; k% 28TargetFramworkMoniker-%22. NETFRAMEWORK, VERSION=V4.% 22% 29; k% 28DevLang- CSHARP%29 & amp;rd= true" rel=" nofolpol " > Mutex

using System;
using System.Threading;

class Test
{
    // Create a new Mutex. The creating thread does not own the
    // Mutex.
    private static Mutex mut = new Mutex();
    private const int numIterations = 1;
    private const int numThreads = 3;

    static void Main()
    {
        // Create the threads that will use the protected resource.
        for(int i = 0; i < numThreads; i++)
        {
            Thread myThread = new Thread(new ThreadStart(MyThreadProc));
            myThread.Name = String.Format("Thread{0}", i + 1);
            myThread.Start();
        }

        // The main thread exits, but the application continues to
        // run until all foreground threads have exited.
    }

    private static void MyThreadProc()
    {
        for(int i = 0; i < numIterations; i++)
        {
            UseResource();
        }
    }

    // This method represents a resource that must be synchronized
    // so that only one thread at a time can enter.
    private static void UseResource()
    {
        // Wait until it is safe to enter.
        mut.WaitOne();

        Console.WriteLine("{0} has entered the protected area", 
            Thread.CurrentThread.Name);

        // Place code to access non-reentrant resources here.

        // Simulate some work.
        Thread.Sleep(500);

        Console.WriteLine("{0} is leaving the protected area
", 
            Thread.CurrentThread.Name);

        // Release the Mutex.
        mut.ReleaseMutex();
    }
}

Answer 3

(在撰写时是正确的,但我认为使用 )更清楚、基本相同。

一次一线可以执行块块

private object once = new object();

public void setOutput(int value)
    {
        lock (once)
        {
            try
            {
                GPOs gpos = reader.Config.GPO;
                gpos[1].PortState = GPOs.GPO_PORT_STATE.TRUE;
                gpos[2].PortState = GPOs.GPO_PORT_STATE.TRUE;
                Thread.Sleep(WAIT);
                gpos[1].PortState = GPOs.GPO_PORT_STATE.FALSE;
                gpos[2].PortState = GPOs.GPO_PORT_STATE.FALSE;
            }
            catch (Exception ex)
            {
                logger.Error("An Exception occure while setting GPO to " + value + " " + ex.Message);
            }
        }
    }

Answer 4

您可以给您的线串命名, 并在方法中检查名称

Answer 5

那么这个解决方案呢?

private AutoResetEvent are = new AutoResetEvent();

public void setOutput(int value)
{
    // Do not wait (block) == wait 0ms
    if(are.WaitOne(0))
    {
        try
        {
            // Put your code here
        }
        finally
        {
            are.Set()
        }
    }
}

与锁定对象的Monitor 相比,似乎更容易(更安全),但也许不太清楚。

友情链接