有没有最好的方法来实现线程之间的延迟?
Is there a best method to implement a delay in between threads?
用例非常简单
我有这个用于启动线程
主要class
for (int x = 1; x <= numThreads; x++)
{
new ThreadComponent(x, this, creator).init();
}
线程class
public void init()
{
thread = new Thread(doLogic);
thread.IsBackground = true;
thread.Start();
}
void doLogic()
{
while (true)
{
doLogicGetData();
}
}
想法是线程执行大约需要。 6秒
我想要 6 个以 1 秒间隔开始的线程
1------1------
2------2------
3------3------
4------4------
5------5------
6------6------
我看到了很多关于使用计时器或 cronjobs 的想法,但我不知道如何以正确的方式实现它们
在 .Net 中解决此问题的另一种 'canonical' 方法是使用任务并行库而不是手动控制线程。下面的控制台程序说明了如何在后台线程上 运行 6 个线程,它们之间有 1 秒的延迟。
class Program
{
public async static Task Main()
{
var cts = new CancellationTokenSource();
List<Task> tasks = new List<Task>();
for (int i = 0; i < 6; i++)
{
tasks.Add(Task.Run(() => DoWork(cts.Token), cts.Token));
await Task.Delay(1000);
}
Console.WriteLine("Press ENTER to stop");
Console.ReadLine();
Console.WriteLine("Waiting for all threads to end");
cts.Cancel();
await Task.WhenAll(tasks);
}
public static void DoWork(CancellationToken token)
{
while (!token.IsCancellationRequested)
{
Console.WriteLine($"Doing work on thread {Thread.CurrentThread.ManagedThreadId}");
Thread.Sleep(10000); // simulating 10 seconds of CPU work;
}
Console.WriteLine($"Worker thread {Thread.CurrentThread.ManagedThreadId} cancelled");
}
}
使用任务并行库的异步编程解释得很好in the documentation
用例非常简单
我有这个用于启动线程
主要class
for (int x = 1; x <= numThreads; x++)
{
new ThreadComponent(x, this, creator).init();
}
线程class
public void init()
{
thread = new Thread(doLogic);
thread.IsBackground = true;
thread.Start();
}
void doLogic()
{
while (true)
{
doLogicGetData();
}
}
想法是线程执行大约需要。 6秒 我想要 6 个以 1 秒间隔开始的线程
1------1------
2------2------
3------3------
4------4------
5------5------
6------6------
我看到了很多关于使用计时器或 cronjobs 的想法,但我不知道如何以正确的方式实现它们
在 .Net 中解决此问题的另一种 'canonical' 方法是使用任务并行库而不是手动控制线程。下面的控制台程序说明了如何在后台线程上 运行 6 个线程,它们之间有 1 秒的延迟。
class Program
{
public async static Task Main()
{
var cts = new CancellationTokenSource();
List<Task> tasks = new List<Task>();
for (int i = 0; i < 6; i++)
{
tasks.Add(Task.Run(() => DoWork(cts.Token), cts.Token));
await Task.Delay(1000);
}
Console.WriteLine("Press ENTER to stop");
Console.ReadLine();
Console.WriteLine("Waiting for all threads to end");
cts.Cancel();
await Task.WhenAll(tasks);
}
public static void DoWork(CancellationToken token)
{
while (!token.IsCancellationRequested)
{
Console.WriteLine($"Doing work on thread {Thread.CurrentThread.ManagedThreadId}");
Thread.Sleep(10000); // simulating 10 seconds of CPU work;
}
Console.WriteLine($"Worker thread {Thread.CurrentThread.ManagedThreadId} cancelled");
}
}
使用任务并行库的异步编程解释得很好in the documentation