在多个任务中调用方法C#

Question

我在调用任务列表中的方法时遇到问题。我有一种方法可以创建 N 个任务。在每个任务中，我都会执行一些操作，最终通过HttpWebRequest 获取数据并将该数据写入文件。我使用锁定对象来锁定对变量等共享资源的访问。除了调用创建一个执行HttpWebRequest（方法GetData）的方法之外，一切都执行得很好。每当我不锁定该方法的调用 (GetData) 时，似乎都会跳过一些数据/文件。例如：

• 使用锁定对象，我得到文件 1、2、3 和 4
• 没有锁定对象我得到文件 2,4 和 3

这是创建任务的方法的代码

private object lockObjectWebRequest= new object();
private object lockObjectTransactions = new object();

public List<Task> ExtractLoanTransactionsData(string URLReceived, string Headers, string Body)
{
    List<Task> Tasks = new List<Task>();

    try
    {
        int Limit = 0;
        int OffsetItemsTotal = 0;
        int NumberOftasks = 4;

        // Create the task to run in parallel
        for (int i = 0; i <= NumberOftasks; i++)
        {
            int OffsetCalculated = 0;

            if (i > 0)
            {
                OffsetCalculated = Limit * i;
            }

            Tasks.Add(Task.Factory.StartNew(() =>
            {
                string URL = URLReceived+ "&offset=" + OffsetCalculated .ToString() + "&limit=" + Limit.ToString();
                string Output = string.Empty;

                lock (lockObjectWebRequest)
                {
                    Output = GetData(URL, Headers,Body);
                }

                if (Output != "[]")
                {
                    lock (lockObjectTransactions)
                    {

                        Identifier++;
                        Job.Identifier = Identifier;

                        // write to file
                        string json = JValue.Parse(Output).ToString(Formatting.Indented);

                        string FileName = OffSet.ToString() + Identifier;
                        string Path = @"C:\FileFolder\" + FileName + ".json";

                        File.WriteAllText(Path, json);
                    }
                }

            }));
        }
    }
    catch (Exception ex)
    {
        Tasks = new List<Task>();
    }

    return Tasks;
}

这是执行HttpWebRequest的代码：

public string GetData(string URL, string Headers, string Body)
{
    string Data = string.Empty;
    Headers = Headers.Trim('{').Trim('}');
    string[] HeadersSplit = Headers.Split(new char[] { ',', ':' });

    HttpWebRequest WebRequest = (HttpWebRequest)HttpWebRequest.Create(URL);
    WebRequest.Credentials = new NetworkCredential();
    WebRequest.Method = "POST";

    HttpWebResponse WebResponse;

    // Set necessary Request Headers
    for (int i = 0; i < HeadersSplit.Length; i = i + 2)
    {
        string HeaderPart1 = HeadersSplit[i].Replace("\"", "").Trim();
        string HeaderPart2 = HeadersSplit[i + 1].Replace("\"", "").Trim();

        if (HeaderPart1 == "Content-Type")
        {
            WebRequest.ContentType = HeaderPart2;
        }
        else if (HeaderPart1 == "Accept")
        {
            WebRequest.Accept = HeaderPart2;
        }
        else if (HeaderPart1 == "Authorization")
        {
            WebRequest.Headers["Authorization"] = HeaderPart2;
        }
    }

    WebRequest.Headers.Add("cache-control", "no-cache");

    // Add body to Request
    using (var streamWriter = new StreamWriter(WebRequest.GetRequestStream()))
    {
        streamWriter.Write(Body);
        streamWriter.Flush();
        streamWriter.Close();
    }

     // Execute Request
     WebResponse = (HttpWebResponse)WebRequest.GetResponse();

     // Validate Response
     if (WebResponse.StatusCode == HttpStatusCode.OK)
     {
         using (var streamReader = new StreamReader(WebResponse.GetResponseStream()))
         {
             Data = streamReader.ReadToEnd();
         }
      }

     return Data;
}

我在这里做错了什么？该方法没有任务之间共享的全局数据。

Answer 1

但您确实有在任务之间共享的数据：本地变量Identifier 和方法参数Job。

您正在使用文件名中的Identifier 写入文件。如果锁没有到位，那段代码将同时运行。

Job 的含义无法从您的问题中推断出来。

我认为您可以通过这样做来解决标识符问题：

var identifier = Interlocked.Increment(ref Identifier);
Job.Identifier = identifier; // Use 'identifier', not 'Identifier'

// write to file
string json = ...;

string FileName = OffSet.ToString() + "_" +
                  "MAMBU_LT_" + DateTime.Now.ToString("yyyyMMddHHmmss") + "_" +
                  identifier; // Use 'identifier', not 'Identifier'
...