Пул потоков

[nikol_]

Обновил предыдущий пост. Теперь есть. Не вру, но не критичен этот код

[GunSmoker]

но не критичен этот код

Это интересный подход. Вы не знаете, в чём проблема, но уже как-то определили, что её нет нигде, кроме вот этих вот пары строчек. Если вы так уверены, что проблемы там нет, то зачем задаёте вопрос?

Зато теперь, когда вы код привели, в последнем коде я вижу отсутствие синхронизации при доступе к pool, itemsInWork и, возможно, isWork (я не знаю точно, потому что код вы опять не привели).

Мой выстрел наугад: из-за отсутствия синхронизации поток ловит Access Violation и самоэкстерминируется.

[nikol_]

Сообщение от GunSmoker

Вы не знаете, в чём проблема, но уже как-то определили, что её нет нигде, кроме вот этих вот пары строчек

Уверен был и пока еще уверен. Уверен потому что код, который идет до создания потоков TLifeOfItem, выполняется нормально без сбоев. Были бы сбои, то к добавлению программа даже не дошла бы, именно исходя из этого я и сделал выводы, что накосячил в создании/старте потока

Сообщение от GunSmoker

Зато теперь, когда вы код привели, в последнем коде я вижу отсутствие синхронизации при доступе к pool, itemsInWork и, возможно, isWork (я не знаю точно, потому что код вы опять не привели).

pool - массив TLifeOfItem, объявлен в описании TNewThread, к этому массиву нигде нет обращений кроме как этих вот пары строчек. Какая для pool нужна синхронизация?

isWork - признак "запущенности" потока на обработку, объявлен в TNewThread. Потоки TLifeOfItem и поток TNewThread не меняют значения isWork, оно меняет значение только в одном месте, когда "пользователь нажмет СТОП"

itemsInWork - список id объявлений,объявлен в TLifeOfItem. Когда поток TNewThread запостил объявление и вырезал id, он пихает это id в itemsInWork. Потоки TLifeOfItem имеют доступ к itemsInWork но только через Synchronize - где поток перед тем как умирать вызывает метод удаления ID из работающих потоков. Но это удаление вызывается только через Synchronize. (но этот код в текущем примере нигде не вызывается, т.е. проблема тоже не в нем)

Сообщение от GunSmoker

Мой выстрел наугад: из-за отсутствия синхронизации поток ловит Access Violation и самоэкстерминируется.

Я думаю, что он хоть гавкнуть об этом должен. Тем более где он может ловить Access Violation? В TLifeOfItem.Create нет, не ловит иначе вообще не запускался =). Дальше, isWork из TLifeOfItem.Execute убрал вообще - результат тот же. Потоки которые были созданы перед добавлением последнего "пропадают"

Сообщение от GunSmoker

зачем задаёте вопрос?

Чтобы вы могли назвать меня вруном, могли попрактиковаться остроумии и тп. и тд. Спасибо большое.

[Человек_Борща]

pool - массив TLifeOfItem, объявлен в описании TNewThread, к этому массиву нигде нет обращений кроме как этих вот пары строчек. Какая для pool нужна синхронизация?

Над массивами есть( и были) многофункциональные обертки, придуманные, ещё в далеком 2002 году...
Вам пора узнать об TList,TObjectList,TCollection и т.д.

Я думаю, что он хоть гавкнуть об этом должен. Тем более где он может ловить Access Violation? В TLifeOfItem.Create нет, не ловит иначе вообще не запускался =). Дальше, isWork из TLifeOfItem.Execute убрал вообще - результат тот же. Потоки которые были созданы перед добавлением последнего "пропадают"

И зачем гавкать, когда можно, просто, посеять указатель на поток, и тупо создать не управляемый обьект в куче. Цитирую:

Потоки которые были созданы перед добавлением последнего "пропадают"

[nikol_]

Человек_Борща, заменил код:

      am:=length(pool);  // узнаю сколько в массиве сейчас потоков
      setlength(pool,am+1); // выделяю место под НОВЫЙ поток
      pool[am]:=TLifeOfItem.Create(idNewItem,'Поток №' + IntToStr(am+1),IdCookieM); // создаю НОВЫЙ поток и пихаю его в массив.
      pool[am].Start; // запускаю НОВЫЙ созданный поток

На вот этот:

      am:=pool.Count;
      pool.Add(TLifeOfItem.Create(idNewItem,'Поток №' + IntToStr(am+1),IdCookieM));
      TLifeOfItem(pool[am]).Start;

На общую ситуацию изменения не повлияли никак...

[9:23:15] - Получение новой капчи
[9:23:15] - !1
[9:23:47] - Капча получена - uawhz7
[9:23:49] - Добавлен новый итем [404253]
Поток №1: [9:23:49] - Начата обработка итема - [404253]
Поток №1: [9:23:49] - Поток №1 обработка итема - [404253]
Поток №1: [9:23:50] - Поток №1 обработка итема - [404253]
[9:23:51] - Добавление нового итема
Поток №1: [9:23:51] - Поток №1 обработка итема - [404253]
[9:23:51] - Получение новой капчи
[9:23:51] - !1
Поток №1: [9:23:52] - Поток №1 обработка итема - [404253]
Поток №1: [9:23:53] - Поток №1 обработка итема - [404253]
Поток №1: [9:24:18] - Поток №1 обработка итема - [404253]
[9:24:18] - Капча получена - snb78r
Поток №1: [9:24:19] - Поток №1 обработка итема - [404253]
Поток №1: [9:24:20] - Поток №1 обработка итема - [404253]
[9:24:20] - Добавлен новый итем [404254]
Поток №2: [9:24:20] - Начата обработка итема - [404254]
Поток №2: [9:24:20] - Поток №2 обработка итема - [404254]
[9:24:22] - Добавление нового итема
Поток №2: [9:24:22] - Поток №2 обработка итема - [404254]
[9:24:23] - Получение новой капчи
[9:24:23] - !1
Поток №2: [9:24:23] - Поток №2 обработка итема - [404254]
Поток №2: [9:24:23] - Поток №2 обработка итема - [404254]

[Человек_Борща]

вы поражаете гениальностью..

      am:=pool.Count; //сколько есть ДО добавления нового обьекта
      //добавляем НОВЫЙ обьект
      pool.Add(TLifeOfItem.Create(idNewItem,'Поток №' + IntToStr(am+1),IdCookieM));
      //ЗАПУСКАЕМ старый поток ЗАНОГО, вместо того, который добавили... 
      TLifeOfItem(pool[am+1]).Start; //<< - ошибка ваша тут

по этому:

      am:=pool.Count-1; //сколько есть ДО добавления нового обьекта
      //добавляем НОВЫЙ обьект
      pool.Add(TLifeOfItem.Create(idNewItem,'Поток №' + IntToStr(am+1),IdCookieM));
      am:=pool.Count-1; //сколько есть ПОСЛЕ добавления нового обьекта      
//ЗАПУСКАЕМ старый поток ЗАНОГО, вместо того, который добавили... 
      TLifeOfItem(pool[am]).Start;

И управлением потокоми(Добовление, изменение, и т.д.) должен заниматься обьектный ПУЛ. Иначе это не Пул т.к. пративоречит этому ваш же код:

      pool.Add(TLifeOfItem.Create(idNewItem,'Поток №' + IntToStr(am+1),IdCookieM));
am:=pool.Count -1; //сколько есть ПОСЛЕ добавления нового обьекта      
//ЗАПУСКАЕМ старый поток ЗАНОГО, вместо того, который добавили... 
      TLifeOfItem(pool[am]).Start;

ваш ПУЛ тупо хранилище потоков, но ни как не ПУЛ потоков. Вы толкаете туда поток, и вы же его запускаете, а этим должен заниматься пул.

[UPD]
Поправил косяки.. Count возвращает количесво элементов включая 0 [0..4] = 5, а обращение к 5-ому элементу станет ERangeError т.к. 5-го элемента нет.

[Аватар]

Человек_Борща с каких пор индекс последнего элемента совпадает с количеством элементов? К-во = 5, индекс от 0 до 4. Ваш пример сразу вывалит ошибку, поскольку выход за пределы. Кто поражает гениальностью ещё вопрос

[Человек_Борща]

Сообщение от Аватар

Человек_Борща с каких пор индекс последнего элемента совпадает с количеством элементов? К-во = 5, индекс от 0 до 4. Ваш пример сразу вывалит ошибку, поскольку выход за пределы. Кто поражает гениальностью ещё вопрос

Tlist - массив указателей, новые элементы пихаются в конец.
Count - вернёт кол-во элементов включая 0-ль.
На момент добовления нового элемента, последний элемент будет = Count.

Или логика не верна? Или Tlist стал на столько не логичным?
или я опять бревно с домом попутал?

[upd]

Просёк фишку=) Опять бревно с домом спутал

[Аватар]

Первый элемент - 0,
последний - Count-1
всего элементов - Count

На момент добовления нового элемента,

До добавления индекс следующнго добавляемого будет равен этому Count если его запомнить до добавления, что тоже самое что Count-1 после добавления