VPF::Многопоточность - Форум программистов

SCAR

Дата 4.1.2013, 23:25 (ссылка)

(нет голосов)

Загрузка ...

Бывалый

Профиль
Группа: Участник
Сообщений: 178
Регистрация: 17.8.2006

Репутация: нет
Всего: нет

Здравствуйте, у меня возникла проблема с выполнением процессов в отдельных потоках.
Необходимо передать объекты в поток, с целью провести определенные вычисления и изменить переданные объекты.
Создаю пул потоков и получаю исключение System.NotSupportedException на WaitHandler.WaitAll.

Код


public static void fillSubPathIntersections()
        {
            int i = 0;

            ManualResetEvent[] events = new ManualResetEvent[getFactorial(SegX.Instance.getPathListCount())];

            for(int k = 0; k < SegX.Instance.getPathListCount(); k++)
            {
                Path pth1 = SegX.Instance.getFromPathList(k);
                for(int p = k + 1; p < SegX.Instance.getPathListCount(); p++)
                {
                    Path pth2 = SegX.Instance.getFromPathList(p);

                    int cur = i;
                    events[cur] = new ManualResetEvent(false);
                    
                    ThreadPool.QueueUserWorkItem(new WaitCallback(delegate(object newDelegate) { findIntersectBtwnTwoSubs(ref pth1, ref pth2, ref events[cur]); }));
                    ++i;
                }
            }
            WaitHandle.WaitAll(events);
        }


private static void findIntersectBtwnTwoSubs(ref Path pth1,ref Path pth2, ref ManualResetEvent evnt)
        {
            lock (pth1)
            {
                lock (pth2)
                {
                    Dictionary<int, SubPathA> sub1 = pth1.getSubListA();
                    Dictionary<int, SubPathA> sub2 = pth2.getSubListA();

                    foreach (KeyValuePair<int, SubPathA> i in sub1)
                        foreach (KeyValuePair<int, SubPathA> j in sub2)
                        {
                            if (((SubPathA)(i.Value)).getSegmentSize != ((SubPathA)(j.Value)).getSegmentSize && ((SubPathA)(i.Value)).getDetLevel != ((SubPathA)(i.Value)).getDetLevel) continue;
                            findSubPathIntersection(i.Value, j.Value);
                        }
                }
            }
            evnt.Set();
        }

Подскажите пожалуйста, в чем ошибка и как ее исправить?

Это сообщение отредактировал(а) SCAR - 4.1.2013, 23:27

SCAR

Дата 6.1.2013, 21:40 (ссылка)

(нет голосов)

Загрузка ...

Бывалый

Профиль
Группа: Участник
Сообщений: 178
Регистрация: 17.8.2006

Репутация: нет
Всего: нет

Решил проблему при помощи класса Task:

Код


Task[] events = new Task[getFactorial(SegX.Instance.getPathListCount())];
            for(int k = 0; k < SegX.Instance.getPathListCount(); k++)
            {
                Path pth1 = SegX.Instance.getFromPathList(k);
                for(int p = k + 1; p < SegX.Instance.getPathListCount(); p++)
                {
                    Path pth2 = SegX.Instance.getFromPathList(p);

                    int cur = i;
                    events[cur] = Task.Factory.StartNew(() => findIntersectBtwnTwoSubs(ref pth1, ref pth2)); 
                                        
                    ++i;
                }
            }
            Task.WaitAll(events);

Это сообщение отредактировал(а) SCAR - 8.1.2013, 10:09

1 Пользователей читают эту тему (1 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Разработка Windows Forms \| Следующая тема »