1

我有多个线程创建一个public List<List<String>> listOfLists并用数据填充它。完成所有线程后，我想使用主线程list.AddRange()中多个线程中的所有这些列表进行组合listOfLits。

所以，如果我有三个线程并且listOfLists每个线程有 10 个元素，那么listOflists主线程将有 30 个元素。只需简单地添加它们，主线程对象必须具有线程插入的所有数据。

如果我static使用listOfLists. 我要做的就是摆脱static.

这是一个小例子。

  1. 我创建了一个简单的 Person 对象（主线程）
  2. 主线程调用一个方法创建3个线程
  3. 这些线程中的每一个都调用另一个方法来填充自己listOfLists的数据
  4. 在该方法结束时，我将自己的线程添加listOfLists到static listOfLists
  5. 这就是我想要避免的。不能有任何静电。
  6. 我只想让这些线程数据在我的主线程中可用，并在主线程上继续应用程序。

编辑：它必须是 .NET 3.5

Edit2：一种解决方案似乎是在启动线程时提供 listOfLists （主线程）的引用作为参数。有没有其他方法可以解决这样的线程问题？

namespace Threading
{
    class Program
    {
        static void Main(string[] args)
        {
            Person p = new Person("mainThread");
            p.startMultiThreading();
        }                   
 }

class Person
{
    public String name;
    public List<String> privatePet;
    public List<List<String>> listOfLists = new List<List<string>>();
    public static List<List<String>> familyPets = new List<List<string>>();

    public Person(String n) { name = n; } //constructor
    public Person() { }

    public void startMultiThreading()
    {
        List<Thread> list_threads = new List<Thread>();
        for (int i = 0; i < 3; i++)
        {
            Person multiThreadPerson = new Person("multi: " + i); //create new Person
            Thread t = new Thread(multiThreadPerson.fill_List); //create new Thread
            t.Name = multiThreadPerson.name; //name the Thread with PersonName

            list_threads.Add(t);
            list_threads[i].Start(); //new Person is calling fill_list()
        }

        for (int i = 0; i < list_threads.Count; i++)
        {
            list_threads[i].Join();
        }

        familyPets.Add(new List<string>{"this is mainthread again"});
        foreach (List<String> list in familyPets)
        {
            list.ForEach(e => Debug.WriteLine(e));
        }
    }

    public void fill_List()
    {
        privatePet = new List<string>();
        lock (familyPets)
        {
            for (int i = 0; i < 20; i++)
            {
                privatePet.Add("dog :" + Thread.CurrentThread.Name);
                privatePet.Add("cat :" + this.name);
                listOfLists.Add(privatePet);
            }
            familyPets.AddRange(listOfLists); //adding up all listOfLists to the mainthread listOfLists
        }//lock 
    }
}
4

3 回答 3

1

除了ThreadStart委托之外，您还可以使用委托创建线程ParameterizedThreadStart，然后Start()使用带有单个对象参数的重载。您可以使用需要传递到线程的 delgate 的任何信息来创建该对象，在这种情况下，它只是您关心的列表的单个列表。

另请注意，您的锁定范围如此之广，以至于只能让一个这样的线程执行任何操作，从而破坏了多线程。您希望他们自己处理只有他们可以处理的事情（privatePet例如，在这种情况下，并且还i因为每个线程都有自己独立的视图。Thread.CurrentThread是静态但线程安全的（否则将毫无意义），而this不是线程安全的并且是共享的，在零线程写入时从字符串字段读取多个线程是安全的（您可以通过使您更安全name readonly，然后您可以通过查看 100% 的信心知道那段代码什么都不会写给它，除非它特意把事情搞砸了。

public void fill_List(object targetList)
{
    List<List<String>> familyPets = (List<List<String>>)targetList;
    List<List<String>> listOfLists = new List<List<String>>();//we'll use our own local one of these thanks, as it's just this thread's concern write now.
    privatePet = new List<string>();
    for (int i = 0; i < 20; i++)
    {
        privatePet.Add("dog :" + Thread.CurrentThread.Name);
        privatePet.Add("cat :" + this.name);
        listOfLists.Add(privatePet);
    }
    //note you don't need to lock until you are doing something
    //that hits on something that other threads might hit on.
    //otherwise you've just got each thread locked for their entire
    //duration and you might as well just do the whole thing
    //in one thread.
    lock (familyPets)
    {
        familyPets.AddRange(listOfLists); //adding up all listOfLists to the mainthread listOfLists
    } 
}

然后在调用方法中，设置列表并将其传递给start：

list_threads[i].Start(whateverTheListIsCalled);
于 2012-09-06T21:06:32.343 回答
0

我认为问题在于您使用同一类“Person”来填充数据和连接数据。

Person p = new Person("mainThread");

从不调用 fill_List() 并且不使用变量 privatePet 和 listOfLists。

在不过多修改代码的情况下，一个简单的解决方案是添加一个新的构造函数：

public Person(String n, List<List<String>> pRefFamilyPets) { name = n; familyPets = pRefFamilyPets; } //constructor

并覆盖这一行，添加 familyPets 参考

Person multiThreadPerson = new Person("multi: " + i, familyPets); //create new Person

我无法遵循逻辑，但这似乎避免了使用 STATIC，因为您将引用传递给其他线程。

于 2012-09-06T21:05:55.550 回答
0 
Enumerable.Range(0, 3).AsParallel().WithDegreeOfParallelism(3).Select(n => {
    var list = new List<string>();
    list.Add(n + ": One");
    list.Add(n + ": Two");
    list.Add(n + ": Three");
    return list;
}).ToList();

或者合并列表：

Enumerable.Range(0, 3).AsParallel().WithDegreeOfParallelism(3).Select(n => {
    var list = new List<string>();
    list.Add(n + ": One");
    list.Add(n + ": Two");
    list.Add(n + ": Three");
    return list;
}).Aggregate((a, b) => a.Union(b).ToList());

阅读 MSDN 上的 Tasks 和 Parallel。

于 2012-09-07T07:56:45.147 回答