在循环中增加一个变量，对于每个增量，应用到每个新线程

Question

每次我创建一个新的Thread 并存储该值时，如何增加一个变量？我想在每个线程中为不同的数据库做 mysqlbackup，我会在 Class1.cs 上完成 curBytes/totalBytes。我想将该值更新为datagridview.Row[iterate].Cell[2] 在线程之间同时进行，其中迭代对应于第一个线程的值 0，第二个线程的值 1，依此类推。

我尝试过使用Interlocked.Increment 和lock()，但它们似乎不起作用。我不想使用BackgroundWorker。

这是我没有做任何更改的代码datagridIterate（遍历datagridview Rows的值）

Form.cs：

private void button1_Click(object sender, EventArgs e)
{
    restoreUI();
}

public void restoreUI()
{
    mysqlUtils msu = new mysqlUtils(); 
    foreach(DataGridViewRow row in dataGridView1.Rows)
    {
        Thread t = new Thread(() =>
        {
            msu.Restore(row.Cells[1].Value?.ToString(), server.Text, username.Text,
                pwd.Text, row.Cells[0].Value?.ToString());
        }
        t.Start();
    }
}

Class1.cs：

namespace Utils
{
    public class mysqlUtils
    {
        public int total;
        public int cur;

        public void Restore(string filename, string server, string user,
            string password, string db)
        {
            string constring = "server=" + server + ";user=" + user +
                ";pwd=" + password + ";database=" + db + ";";
            string file = "C:\\Users\\SQL FILES\\" + filename;
            using (MySqlConnection conn = new MySqlConnection(constring))
            {
                using (MySqlCommand cmd = new MySqlCommand())
                {
                    using (MySqlBackup mb = new MySqlBackup(cmd))
                    {
                        cmd.Connection = conn;
                        conn.Open();

                        mb.ImportInfo.IntervalForProgressReport = 50;

                        mb.ImportProgressChanged += updateProgress;
                        mb.ImportFromFile(file);

                        conn.Close();
                    }
                }
            }
        }
    }

    public void updateProgress(object sender, ImportProgressArgs e)
    {
        total = (int)e.TotalBytes;
        cur = (int)e.CurrentBytes;
        Form4 form4 = (Form4)Application.OpenForms[0];
        form4.updateProgressValue(total, cur);
    }
}

我应该如何设法更改datagridIterate，它的值i 用于第一个线程，i+1 用于下一个线程等等？如果您有任何支持，我将不胜感激。

Answer 1

这里有一个重要的代码提示，可以帮助你理解你需要什么。

试试这个：

public class Form4 : Form
{
    private DataGridView dataGridView1 = new DataGridView();
    private TextBox server = new TextBox();
    private TextBox username = new TextBox();
    private TextBox pwd = new TextBox();

    private void button1_Click(object sender, EventArgs e)
    {
        RestoreUI();
    }

    public void RestoreUI()
    {
        MySqlUtils msu = new MySqlUtils();
        foreach (DataGridViewRow row in dataGridView1.Rows)
        {
            string filename = row.Cells[1].Value?.ToString();
            string s = server.Text;
            string user = username.Text;
            string password = pwd.Text;
            string db = row.Cells[0].Value?.ToString();
            Thread t = new Thread(() => msu.Restore(filename, s, user, password, db, UpdateProgress));
            t.Start();
        }
    }

    public void UpdateProgress(object sender, ImportProgressArgs e)
    {
        this.Invoke((Action)(() =>
        {
            /* add your code here to update the UI */
        }));
    }
}

还有你的MySqlUtils 班级。

public class MySqlUtils
{
    public void Restore(string filename, string server, string user, string password, string db, ImportProgressChange updateProgress)
    {
        string constring = "server=" + server + ";user=" + user + ";pwd=" + password + ";database=" + db + ";";
        string file = "C:\\Users\\SQL FILES\\" + filename;
        using (MySqlConnection conn = new MySqlConnection(constring))
        {
            using (MySqlCommand cmd = new MySqlCommand())
            {
                using (MySqlBackup mb = new MySqlBackup(cmd))
                {
                    cmd.Connection = conn;
                    conn.Open();

                    mb.ImportInfo.IntervalForProgressReport = 50;

                    mb.ImportProgressChanged += updateProgress;
                    mb.ImportFromFile(file);

                    conn.Close();
                }
            }
        }
    }
}

注意：我已将命名约定更改为标准 C#。