使用异步等待方法填充数据网格

Question

我的英语不是很好，抱歉，但我尝试完美地讲述我的问题

这是我加载数据网格的内容

private Task Loading(Func<string> SearchStringForUser)
{

    return Task.Run(() =>
    {

        var query = database.Database.SqlQuery<VW_Users>("select * From VW_Users where 1 = 1 And GymID = " + PublicVar.ID + " " + SearchStringForUser());
        var user = query.ToList();
        Dispatcher.InvokeAsync(() =>
        {
            DataGrid_User.ItemsSource = user;
        });
    });
}

首先，我有一个 InvokeAsync 但它不能完美工作，我的意思是当加载的数据将列出时我的程序会挂起。不管怎样，这不是我的主要问题，但如果有人知道原因是什么，可以指出它，但我的主要问题是当我有+200行时。程序不会在 30 秒或更长时间内加载所有日期。看起来我的程序数据网格有 30 秒或更长时间为空。

我想按 10 行 10 行加载数据，我的意思是我想在加载 10 行时填充我的数据网格，在接下来的 10 行之后，例如 10 20 30 40 .... 这样我的数据网格将永远不会为空，并且数据将缓慢加载有人可以告诉我最好的方法吗？

Answer 1

您应该在后台线程上调用数据库，但ItemsSource在 UI 线程上设置属性。所以你Task应该返回 anIEnumerable<User>但不要碰DataGrid. 然后你就可以等待了Task。

Loading如果从 UI 线程调用该方法，这应该可以工作：

private async Task Loading(Func<string> SearchStringForUser)
{
    var user = await Task.Run(() =>
    {
        var query = database.Database.SqlQuery<VW_Users>("select * From VW_Users where 1 = 1 And GymID = " + PublicVar.ID + " " + SearchStringForUser());
        return query.ToList();
    });
    DataGrid_User.ItemsSource = user;
}

但由于查询一次返回所有行，因此不存在“加载 10 行时”。你一下子就得到了它们。如果您不希望这样做，则需要使用某种数据读取器来逐条读取记录。您可以创建一个ObservableCollection并每隔一段时间填充这个。这是一个应该能让您有所了解的示例：

ObservableCollection<VW_Users> collection = new ObservableCollection<VW_Users>();
object @lock = new object();
BindingOperations.EnableCollectionSynchronization(collection, @lock);
DataGrid_User.ItemsSource = collection;

Task.Run(() =>
{
    using (SqlConnection connection = new SqlConnection("connection string...."))
    {
        SqlCommand command = new SqlCommand("select * From VW_Users where GymID = @GymId", connection);
        command.Parameters.AddWithValue("GymId", PublicVar.ID + " " + SearchStringForUser());
        connection.Open();

        SqlDataReader reader = command.ExecuteReader();
        if (reader.HasRows)
        {
            const int N = 10;
            VW_Users[] cache = new VW_Users[N];
            int counter = 0;
            while (reader.Read())
            {
                VW_Users obj = new VW_Users();
                obj.Property1 = Convert.ToString(reader["Column1"]);
                cache[counter] = obj;
                //...and so on for each property...

                if (++counter == N)
                {
                    //add N items to the source collection
                    foreach (VW_Users x in cache) collection.Add(x);
                    counter = 0;
                    //add a delay so you actually have a chance to see that N items are added at a time
                    System.Threading.Thread.Sleep(1000);
                }
            }
            //add any remaining items
            for (int i = 0; i<counter; ++i) collection.Add(cache[i]);
        }
        reader.Close();
    }
});