[pro100kos]

Пытаюсь перебирать так ничего не выходит скорость никак не меняется. Подскажите пожалуйста в чем может быть причина

Код:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65

...... type   TMyThread = class(TThread)   private   protected     procedure Execute; override;     procedure memoAdd;   public     msg:string;     N:integer;   end;    .......   private     MyT:array of TMyThread;   public      o:integer;      CounArray:integer;   end; .........    procedure TMyThread.Execute; var //nw :string;     b,A:integer; begin dm.AdUpdatePOsitions.ExecSQL; b:= N  * form5.CounArray; //Присваеваем единицу A :=  b - form5.CounArray;      while A <> b do   begin     inc(A);       msg:= inttostr(A) + ' Поток номер '+ inttostr(N) +' запущен! '+inttostr(Form5.o)+' '+dm.AdUpdatePOsitions.FieldByName('Words').AsString;     Synchronize(memoAdd);     dm.AdUpdatePOsitions.Next;   end; end;    procedure TMyThread.memoAdd; begin   Form5.Memo1.Lines.Add(msg); end;    procedure TForm5.BitBtn1Click(Sender: TObject); var i,nn:integer; begin   dm.AdUpdatePOsitions.SQL.Clear;   dm.AdUpdatePOsitions.SQL.Add('SELECT * FROM Position');   dm.AdUpdatePOsitions.Active:=True;   dm.AdUpdatePOsitions.first;      nn := dm.AdUpdatePOsitions.RecordCount; //подсчет количества данных в массиве   CounArray :=  Trunc ( nn /  SpinEdit1.value );   //округлим в меньшую сторону       //создание потоков   for i := 1 to SpinEdit1.value do begin     SetLength(MyT,i+1);     MyT[i]:=TMyThread.Create(True);     MyT[i].Priority:= tpLowest;     MyT[i].N:=i;     MyT[i].FreeOnTerminate:=True;     MyT[i].Start;   end; end;

[Guaho]

Если потоков много, а датасет один, то будет ли быстрее?
По идее надо создать несколько датасетов, по числу потоков, чтоб каждый поток работал только со "своим" датасетом.

[lmikle]

Guaho, в общем правильно, но можно сделать и с одним источником, просто использовать его как очередь заданий. Имеет смысл если только обработка одной записи занимает некоторое время, иначе все потоки будут "толпиться" на доступе к этому компоненту.
Что бы такое сделать, надо использоывть объекты синхронизации для блокировки доступа к ДатаСету, т.к. каждый поток при получении данных сначала блокирукт CriticalSection, потом делает ДатаСету Next, читает данные из записи, снимает блокировку и уже потом начинает обрабатывать данные внутри себя.

[pro100kos]

Обработка данных будет занимать около 5 секунд в одном потоке, потом будет переход на следующую строку в БД. Что можете порекомендовать в этом случае?

[Kailon]

Хотелось бы уточнить, а как именно Вы обрабатываете запись? В запросе Вы выбираете все поля, но если их много и не все требуются, то может имеет смысл выбрать только нужные. А ещё я бы порекомендовал в циклах не использовать FieldByName, а обращаться к полю по его индексу через Fields[]. Про это даже в справке написано.

[Guaho]

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

Обработка данных будет занимать около 5 секунд...

Как-то многовато! Не знаю, что там делается, но может имеет смысл попытаться написать код так, что эту "обработку" ускорить? Кроме того, если уж делать с потоками, тогда надо проверять, чтоб разные потоки не обрабатывали одну и ту же запись одновременно (возможно, проверять свойство State). Ну и сделать число датасетов по числу потоков - как по мне, самое простое решение.

[OnlyTheProg]

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

Как-то многовато! Не знаю, что там делается, но может имеет смысл попытаться написать код так, что эту "обработку" ускорить? Кроме того, если уж делать с потоками, тогда надо проверять, чтоб разные потоки не обрабатывали одну и ту же запись одновременно (возможно, проверять свойство State). Ну и сделать число датасетов по числу потоков - как по мне, самое простое решение.

А есть ещё какие-нибудь варианты?
Crypto-checker https://chrome.google.com/webstore/detail/crypto-checker/bahhmhhmnedfhndhdagobnknhcflhhkp?hl=ru - расширение для начинающих трейдеров, которое может помочь им в выборе криптовалютной биржи, обойти стороной мошенников и проводить криптоарбитраж безопасно

[pro100kos]

В общем в потоке все перебирает отлично, но вот делаю запись в бд Access через синхронизацию
использую вот эту функцию RecordPositions. Создается большая очередь и программа работает не очень быстро из-за этого как можно произвести запись прямо в потоке? (например без синхронизации)

Код:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15

function RecordPositions(a,b,c:integer; d,e,r,t:string):string; begin       dm.AdQ_Pos1.Active:=true;       dm.AdQ_Pos1.Append;       dm.AdQ_Pos1.FieldByName('t').AsString := t;       dm.AdQ_Pos1.FieldByName('b').AsInteger := b;       dm.AdQ_Pos1.FieldByName('c').AsInteger := c;       dm.AdQ_Pos1.FieldByName('d').AsString := d;       dm.AdQ_Pos1.FieldByName('e').AsString := e;       dm.AdQ_Pos1.FieldByName('r').AsString := r;       dm.AdQ_Pos1.FieldByName('a').AsInteger := a;       dm.AdQ_Pos1.POST;       dm.AdQ_Pos1.Active:=false;       Exit; end;