Unity中SQL查询引发CPU卡顿的优化方案与技术疑问

问题背景 #

在Unity中用C#编写SQL查询程序，最初用Coroutine实现，每次查询CPU占用高、程序无响应约2秒；改用async/Task.Delay后问题依旧。Profiler显示99.4% CPU消耗来自DbDataAdapter.Fill()，最终指向Socket.Receive_icall()，推测是同步等待查询结果导致主线程阻塞。

相关代码片段：

async Task parseSQLData () { // 每次运行都会占用环境资源的函数
    while (true){
        output.text = sqlStream.readSQL(); // 读取另一个脚本中存储的SQL流数据
        new_reading = true; // 完成后切换标识，让Update()可以显示变更
        await Task.Delay(7000); // 等待约12分钟，因为数据表每约15分钟更新一次。
    }
}

...

public string readSQL () {
    // 所用的SQL查询语句，会提取一个约600字符的DataTable。
    string sql = @"SELECT TOP (20) [7 Different Columns]
                    FROM [SomeDB]  
                    WHERE (Timestamp >= '2023-08-01')
                    AND ([Conditionals based on columns above])
                    ORDER BY [Timestamp] DESC";
    // 使用已在其他位置建立的连接字符串查询数据库
    DataTable result = ExecuteSqlQuery (builder, sql);

    // 将DataTable对象解析为字符串，行内元素用" ; "分隔
    string beans = string.Join(Environment.NewLine, result.Rows.OfType<DataRow>().Select(x => string.Join(" ; ", x.ItemArray)));
    return beans;
}

核心疑问：

• 用Coroutine/Async能否优化缓解卡顿？是否必须用IJobs？
• readSQL是否需要改为异步函数？
• Async是否会控制整个线程而不管内部函数？

优化方案与解答 #

1. readSQL必须改为异步函数，同步IO是卡顿根源
   目前readSQL里的ExecuteSqlQuery和DbDataAdapter.Fill()都是同步操作，会直接阻塞Unity主线程，直到SQL查询完成（包括网络等待和数据读取）。必须把所有IO相关操作换成异步版本：

   • 将ExecuteSqlQuery替换为异步实现，比如使用DbDataAdapter.FillAsync()替代Fill()，或者用SqlCommand.ExecuteReaderAsync()等异步API
   • 修改readSQL为async Task<string>，内部所有异步操作都用await等待，避免阻塞主线程

2. Coroutine/Async框架下完全可以解决卡顿，无需立刻使用IJobs
   只要把同步IO改为异步await，主线程在等待SQL查询结果时会释放资源去处理渲染、输入等逻辑，不会出现无响应的情况。IJobs更适合CPU密集型的计算任务，而你的问题是IO阻塞导致的，异步IO足以解决。

3. Async不会控制整个线程，关键看内部是否用异步操作
   Async只是语法糖，本身不会强制线程切换。如果readSQL里全是同步代码，即使parseSQLData是async方法，调用readSQL()时依然会在主线程执行直到完成，导致阻塞。只有当内部使用了await真正的异步方法（比如异步IO、Task.Run封装的CPU任务）时，才会把线程控制权交还给Unity主线程。

修改后的代码示例 #

async Task parseSQLData () {
    while (true){
        // 异步等待查询结果，不会阻塞主线程
        output.text = await sqlStream.readSQLAsync(); 
        new_reading = true;
        await Task.Delay(720000); // 12分钟，对应原注释的15分钟更新频率
    }
}

...

public async Task<string> readSQLAsync () {
    string sql = @"SELECT TOP (20) [7 Different Columns]
                    FROM [SomeDB]  
                    WHERE (Timestamp >= '2023-08-01')
                    AND ([Conditionals based on columns above])
                    ORDER BY [Timestamp] DESC";
    // 使用异步版本的查询方法
    DataTable result = await ExecuteSqlQueryAsync(builder, sql);

    string beans = string.Join(Environment.NewLine, result.Rows.OfType<DataRow>().Select(x => string.Join(" ; ", x.ItemArray)));
    return beans;
}

// 异步查询的实现示例
private async Task<DataTable> ExecuteSqlQueryAsync(SqlConnectionStringBuilder builder, string sql)
{
    var dt = new DataTable();
    using (var conn = new SqlConnection(builder.ConnectionString))
    {
        await conn.OpenAsync();
        using (var cmd = new SqlCommand(sql, conn))
        using (var adapter = new SqlDataAdapter(cmd))
        {
            // 用FillAsync替代同步Fill
            await adapter.FillAsync(dt);
        }
    }
    return dt;
}

内容的提问来源于stack exchange，提问作者Khepri