0

我有一个查询本地数据库并将其发布到 Web api 的任务。目前它需要所有行，将它们分成 500 个块，然后使用异步线程设置同时发布它们。我有另一项工作，偶尔会从服务器获取数据，我在想，如果我返回服务器负载并将其存储在 中Config.ServerLoad，如果服务器受到重击，它可能会稍微隔开请求。这是我用来设置线程的代码：

var json = JsonConvert.SerializeObject(rowDto);
var threads = new Thread(new ParameterizedThreadStart(MultiThreadPostThead));
var thisThread = new PostParams() { postUrl = postUrl, json = json, callingThread = threads };
threads.Start(thisThread);
threads.IsBackground = true;
ThreadHandles.Add(thisThread);

我希望添加这样的内容：

thread.delay(Config.ServerLoad * 1000);

例如，如果服务器负载为 0.5，则线程之间几乎没有延迟，但如果为 10，则帖子之间将等待 10 秒。我看到了一些关于 a 的信息Task.Delay()，但没有看到任何关于线程的信息。我错过了什么有助于增加动态值延迟或设置最大并发线程数？

4

2 回答 2

1

如果您想延迟新线程的启动，那么您可以执行以下操作

PerformanceCounter cpuCounter;
cpuCounter = new PerformanceCounter("Processor", "% Processor Time", "_Total");

var thisThread = new PostParams() { postUrl = postUrl, json = json, callingThread = threads };
Thread.Sleep((int)(cpuCounter.NextValue() * 1000));
threads.Start(thisThread);

您可以做的另一件事是使用

threads.Sleep((int)(cpuCounter.NextValue() * 1000));

因为它是一个线程，所以应该有可用的方法

这应该获取当前的 Cpu 使用情况，然后在启动新线程之前将当前线程休眠一段时间 - 如果您已经在 Config 中存储了一个数字，那么您可以放弃执行上下文内容并将其替换为您拥有的值： )

于 2018-06-12T16:38:32.450 回答
0

我自己通常不使用线程，但更喜欢您提到的任务。

.Net 有一个非常直接的异步设计模式；通过声明您的方法 async 您定义该方法始终应该在异步上下文中调用。如果您选择使用以下示例，您将不再需要等待一定的时间，而是在完成任务后继续异步执行。

    public class MyResult {
        public string Result;
    }

    public async void Program() {

        var Timeout = 1000;
        Task<MyResult> Assignment = GetResult();

        // two ways of getting output:
        // 1: We wait using the task library
        Task.WaitAll(new Task[] { Assignment }, Timeout);
        MyResult r1 = Assignment.Result;

        // 2: We wait using the async methods:
        MyResult r2 = await Assignment;
    }

    public async Task<MyResult> GetResult() {
        // You can find methods which by default is async, therefore not needing to start the task yourself.
        return await Task.Factory.StartNew(() => LoadFromDatabase());
    }

    private MyResult LoadFromDatabase() {
        // Just testing.
        return new Question1.StartingTasks.MyResult() { Result = "TestResult" };
    }

如果您不熟悉异步方法，我建议您使用一些简单的类，例如这个示例，来了解这些方法的行为。

- - 额外的

如果你使用Task.Delay(Time)没有成功，你要记得等待Task完成，例如Task.WaitAll(Task.Delay(500));

于 2018-06-12T17:25:54.177 回答