如何在 C# 中创建基于 DataTable.Rows.Count 的对象？

下面的所有代码仅创建两个进程。虽然我需要创建 n 个进程来打开 Chrome 浏览器并运行OpenNRowsInData(user, pwd)基于dtUser.Rows.Count因为这是动态的。

我不知道为什么OpenNRowsInData(user, pwd);总是只获取第一行。

我有一个DataTable范围为 1-7 行。

通常，我通常用来创建两个对象。

static myObject[] browser = new myObject[] { 
          new myObject(Browsers.Chrome, 0), 
          new myObject(Browsers.Chrome, 0)
};

Thread t1, t2;

t1 = new Thread(new ThreadStart(AllCase))
{
    Name = "Thread1"
};
t1.Start();

t2 = new Thread(new ThreadStart(AllCase))
{
    Name = "Thread2"
};
t2.Start();

在班上AllCase:

static int[] stepRun = { 0, 0 };
private void AllCase()
{
    int idx = int.Parse(Thread.CurrentThread.Name.Replace("Thread", "")) - 1;
    switch (stepRun[idx])
    {
        case 0:
            foreach (DataRow row in dtUser.Rows)
            {
                user = row["user"].ToString();
                pwd = row["pwd"].ToString();
                OpenNRowsInData(user, pwd);
            }
            break;
        case 1:
            ClickBuy();
            break;
    }
}

在另一个例子中，在我使用并行进程之前。目前，我不想使用它。

Parallel.ForEach(
    dtUser.AsEnumerable(),
    items => OpenNRowsInData(items["user"].ToString(), items["pwd"].ToString()));

我只想获取列user and pwd.

尝试使用代码，我尝试添加一个参数action()方法如：action(string user, string pwd).

public static void ForEach<T>(this IEnumerable<T> source, Action<T> action)
{
    if (source == null) throw new ArgumentNullException("source");
    if (action == null) throw new ArgumentNullException("action");

    foreach (T item in source)
    {
        action(item);
    }
}

Updated:

添加班级OpenNRowsInData(string username, string password):

private void OpenNRowsInData(string username, string password)
{
    int idx = int.Parse(Thread.CurrentThread.Name.Replace("Thread", "")) - 1;
    try
    {
        browser[idx].DeleteAllCookies();
        browser[idx].GoToUrl(link);
        browser[idx].waittingID("txtUserName", 15);
        browser[idx].FindElementById("txtUserName").SendKeys(username);
        browser[idx].FindElementById("txtpassword").SendKeys(password);
        browser[idx].FindElementById("btnlogin").Click();
        stepRun[idx] = 1;
        AllCase();
    }
}

我不知道为什么 OpenNRowsInData(user, pwd);总是只获取第一行。

在我看来，你的第二次威胁来得太快了。在第一个完成之前它将执行ClickBuy();所以只能处理第一行。

尝试一步一步地做

AllCase(0, 0);
AllCase(1, 0);


private void AllCase(int case, int browserNr)
{
    switch (case)
    {
        case 0:
            foreach (DataRow row in dtUser.Rows)
            {
                user = row["user"].ToString();
                pwd = row["pwd"].ToString();
                OpenNRowsInData(user, pwd, browserNr);
            }
            break;
        case 1:
            ClickBuy();
            break;
    }
}

private void OpenNRowsInData(string username, string password, int browserNr)
{      
    try
    {
        browser[browserNr].DeleteAllCookies();
        browser[browserNr].GoToUrl(link);
        browser[browserNr].waittingID("txtUserName", 15);
        browser[browserNr].FindElementById("txtUserName").SendKeys(username);
        browser[browserNr].FindElementById("txtpassword").SendKeys(password);
        browser[browserNr].FindElementById("btnlogin").Click();
    }
}

如果您想对两个浏览器执行此操作，请尝试在数组上运行循环：

for(int j = 0; j < browser.Length;j++)
{
    AllCase(0, j);
    AllCase(1, j);
}

这次并行化实际上会得到回报。因为你可以同时在两个浏览器中执行相同的操作，但似乎你不应该同时执行这两个操作AllCase- 案例the same同时浏览器，因为它们是连续的

EDIT:

编辑后，似乎当您第一次进入循环时OpenNRowsInData在该位置0

stepRun[idx] = 1;

然后再打电话

AllCase();

这次会执行

    case 1:
        ClickBuy();
        break;

在第二次迭代时，它将再次尝试打开

switch (stepRun[idx])

但这一次它会找到一个1在位置上0 in stepRun。对全部 永远不要回到箱子里打电话OpenNRowsInData。 这就是为什么你只得到第一行。

EDIT 2:

如果您想在两个浏览器中同时执行此操作，您可以创建一个例程来执行这两种情况AllCase and this您可以在 2 个单独的线程中运行例程：

public void doEverything(int browserIndex)
{
    AllCase(0, browserIndex);
    AllCase(1, browserIndex);
}

并像这样启动线程：

for(int j = 0; j < browser.Length;j++)
{
    int brInd = j;
    Thread t= new Thread(()=>doEverything(brInd));
    t.Start();
}

您还可以将整个浏览器对象传递给该方法，然后将其进一步传递给OpenNRowsInData并在那里使用它