How to implement a thread queue to run one after another?

Question

How to implement a thread queue to run one after another?

Navigation

#1 by (1 votes)

4

I have a static method to write logs to my system.

public class Logger
{
    public static void SaveLog(string[] lines)
    {
        System.IO.File.WriteAllLines(@"C:\...\Temp\ExceptLog.txt", lines);
    }
}

The method is used in several places and access the same text file.

I would like to know how to implement a thread queue in C # to avoid conflicting concurrent access to the file.

How can a queue of threads be executed to run one by one in the background in order to avoid concurrent access conflict and thus not "mess up" the main thread?

c# thread fila-thread

asked by anonymous 19.06.2014 / 05:12

1 answer

Detect event generated in another class Import file from phonegap / cord in eclipse

score 1 · Accepted Answer

Instead of creating a thread queue, why not create a queue of messages that are going to be written? So it could have a unique thread that wrote the messages and avoided the problem of access, thus creating a producer / consumer system.

The steps, roughly speaking, would be:

Put the log writing code inside an action;

Put this action in blocking collection ;

Have a% of dedicated logging that consumes thread and execute the received actions, thus guaranteeing the sequential writing of the logs in the file;

An implementation based on the points back:

var LogCollection = new BlockingCollection<Action>();

public static void LogMessage(string messageToLog)
{
    LogCollection.Add(() => File.WriteAllText("", messageToLog));
}

public static void WriteLogMessages(CancellationToken token)
{ 
    foreach (var msg in LogCollection.GetConsumingEnumerable(token))
    {
        msg();
    }
}

Using it would look like this:

public static void Main()
{
    using (CancellationTokenSource cts = new CancellationTokenSource())
    {
        Thread t1 = new Thread(() => WriteLogMessages(cts.Token));
        t1.Start();
        LogMessage("Hello World");
        Console.ReadKey();
        cts.Cancel();
        t1.Join();
    }
}

Note: For more ideas, and if you're determined to use your own log implementation, take a look at the NLog code for more inspiration.