[mustimur]

Доброго времени суток.

Попробовал написать многопоточную программу (до этого нужды не было в это лезть) и как говорится первый блин комом.
Суть проблемы в следующем программа производит значительное число однотипных расчетов, по сути которые можно обсчитывать параллельно.
С помощью класса TThread создается программой несколько потоков (число потоков определяется пользователь программы) каждый из которых берет на себя равную часть расчетов. Потоки формируются и отрабатывают правильно расчет (проверял) однако скорость осталась прежней, что и с одним потоком. В диспетчере задач показано, что программе присвоен один процесс и загрузка процессора всегда 25%, не зависимо от числа потоков.
Что я не правильно понял?

[PhoeniX]

Кусок кода сказал бы больше, чем 80% вашего сообщения

[mustimur]

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

Кусок кода сказал бы больше, чем 80% вашего сообщения

Я не думаю что легче будет, но код вот:

Код:

itc:=sedt.Value;// Определяет число параллельный потоков
setlength(ther,itc); 
for it := 1 to itc do
  begin
  ther[it-1]:= Rasch.Create(true); //Rasch - мой класс TThread
  ther[it-1].FreeOnTerminate := true;
  if it =1 then ther[it-1].kss:=0 else ther[it-1].kss:=(it-1)*(kg mod itc)+1;// определяет с какого элемента считать начать текущему потоку
  if it=itc then ther[it-1].ke:=kg else ther[it-1].ke:=(it)*(kg mod itc); // определяет каким элементом закончить счет текущему потоку
  ther[it-1].proc:=rasc1; // определяет процедуру для расчета
  ther[it-1].start;
end;
  enp:=false;
  while (enp=false) do //Ожидание окончание всех потоков
  begin
  enp:=ther[0].Finished;
  if itc>1 then for it := 2 to itc do enp:=(enp and ther[it-1].Finished);
  end;

Чтобы было понятнее приложу код класса Rasch

Код:

unit Rasc;

interface

uses
  System.Classes;

type
  ProcRasc = procedure(kstr, kend:integer);
  Rasch = class(TThread)
  private
    { Private declarations }
  public
  
  proc: ProcRasc;
  kss,ke: integer;

  protected
    procedure Execute; override;
  end;


implementation


{ Rasch }

procedure Rasch.Execute;
begin
  proc(kss,ke);
end;

end.

[PhoeniX]

Код:

ther[it-1].start;

Попробуй заменить на

Код:

ther[it-1].resume;

В остальном всё должно работать...

P.S. А, ну и процедуры расчёта должны быть, как говорится, ThreadSafe - думаю, это объяснять не надо?
P.P.S.

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

Я не думаю что легче будет

Мы тут экземпляры класса TProgrammer, и у нас метод Understand заточен под тип сообщений TCode
P.P.P.S. Ну и число потоков лучше рассчитывать из числа процессоров/ядер, а не из объёма работ.

[Bargest]

Небольшое дополнение.

Код:

while (enp=false) do //Ожидание окончание всех потоков
  begin
  enp:=ther[0].Finished;
  if itc>1 then for it := 2 to itc do enp:=(enp and ther[it-1].Finished);
  end;

Было бы логичней

Код:

do
  enp = true;
  for it := 0 to itc - 1 do
    enp := enp and ther[it].Finished;
while (enp = false)

Ну и IF-ы в составлении потоков можно и убрать:

Код:

ther[it-1].kss:=(it-1)*(kg mod itc);
ther[it-1].ke:=(it)*(kg mod itc) - 1;

После чего этот цикл тоже перевести на 0 to itc-1 и повысить читаемость, убрав все -1 и добавив в одном месте +1.

Код:

for it := 0 to itc-1 do
  begin
  ther[it]:= Rasch.Create(true);
  ther[it].FreeOnTerminate := true;
  ther[it].kss:=it*(kg mod itc);
  ther[it].ke:=(it + 1)*(kg mod itc) - 1;
  ther[it].proc:=rasc1;
  ther[it].start;
end;

Проще читается как-то.
ЗЫЖ если я правильно помню, при выставленном FreeOnTerminate поток по завершении самоуничтожается, а ты после этого его флаги читаешь. Не гут.

Сообщение от Спеки Embarcadero

Warning: When FreeOnTerminate is true, the Execute method may run and then free the thread before your application can execute the next line of code. Thus, you should not call any methods of the thread object when FreeOnTerminate is true unless you create the thread in a suspended state. FreeOnTerminate is best left for threads that simply perform a task and then naturally terminate. If you want to communicate with the thread or otherwise interact with it, including telling it when to terminate, FreeOnTerminate should never be used.

[mustimur]

Вы правы Ваш код изящней!!!

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

Проще читается как-то.
ЗЫЖ если я правильно помню, при выставленном FreeOnTerminate поток по завершении самоуничтожается, а ты после этого его флаги читаешь. Не гут.

так я надеюсь на его уничтожение по завершении расчетов и жду этого, когда все потоки уничтожатся, чтобы продолжить... А что не так?

Но главный вопрос при этом коде ни скорость счета ни загрузка процессора не зависит от числа потоков. Процессор всегда загружен на 25% (похоже на одно ядро)!!! Почему??????

[Bargest]

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

Простите комп повис как удалить повторы?

Никак. Попроси модеров (Admin, M.A.D.M.A.N, lmikle). Пока отредактируй и измени текст на < удалено > (т.к. минимум 10 символов).

А что не так?

Поток завершился, объект удалился, а потом ты обращаешься к его полю Finished, т.е. к полю несуществующего объекта. Работать скорее всего будет в большинстве случаев, но только благодаря тому, что память не зануляется при удалении.

(похоже на одно ядро)!!! Почему??????

Приложи еще код расчетов.
ЗЫЖ черт, совсем забыл, что в делфе нет do-while... Надо поменять на repeat-until и условие поставить обратное.

[mustimur]

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

Мы тут экземпляры класса TProgrammer, и у нас метод Understand заточен под тип сообщений TCode .

Шутку оценил

Код:

ther.resume

пробовал результаты теже....