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:
66:
67:
68:
69:
70:
71:
72:
73:
74:
75:
76:
77:
78:
79:
80:
81:
82:
83:
84:
85:
86:
87:
88:
89:
90:
91:
92:
93:
94:
95:
96:
97:
98:
99:
100:
101:
102:
103:
104:
105:
106:
107:
108:
109:
110:
111:
112:
113:

procedure TForm3.FormResize(Sender: TObject);
begin

  finalize(wavebufL);
  finalize(wavebufR);

  buf:= Width - Panel2.Width - Panel3.Width;

  setlength(wavebufL, buf);
  setlength(wavebufR, buf);

  if (length(wavebufL) = buf) and (length(wavebufR) = buf) then//<--musste ich machen weil setlength manchmal nicht funktionierte
  begin

    BASS_ChannelSetPosition(mychan1, BASS_ChannelSeconds2Bytes(mychan1, xpos), BASS_POS_BYTE);

    NewThread:= TScanThread.Create(mychan1, xzoom, buf);
    Newthread.OnUpdatePeaks := MyThreadUpdatePeaks;
  end;

  DrawLevelLine;

end

//------hier im Thread sind die einzigsten Pointer----------
//-----@PeakBuf + Data^
procedure TScanThread.Execute;
var
  PeakBuf: array[0..10400] of integer;  //10400=60ms Daten //1sekunde daten = 176400
  Data: ^smallint;
  rc: integer;
  pl, pr: integer;
  BufLen: Integer;
  counter: integer;
  msec: real;
begin
 inherited;
 try

OutputDebugString('ich arbeite'); //ist nur für mich

  counter:= 0;
  pl:= 0;
  pr:= 0; rc:= Fzoom;
  msec:= 0;
  setlength(FpeaksL, Fbuf);
  setlength(FpeaksR, Fbuf);
  //setlength(FpeaksL, 2600);
  //setlength(FpeaksR, 2600);

  BufLen:= Bass_ChannelGetData(Fdecoder, @PeakBuf, 10400);
  Data:= @PeakBuf;

  while (buflen > 0) do//and (not terminated) do
  begin
    while rc >= 1 do
    begin
      if (Data^) > pl then pl:= (Data^)
      else
      if ((Data^) < pl) and (Fzoom < 6) then pl:= (Data^);
      Inc(Data);

      if (Data^) > pr then pr:= (Data^)
      else
      if ((Data^) < pr) and (Fzoom < 6) then pr := (Data^);
      Inc(Data);

      BufLen:= BufLen -4 ;

      if BufLen <= 0 then
      begin
        msec:= msec + 0.0585;
        //FillChar(PeakBuf, sizeof(PeakBuf), 0);
        BASS_ChannelSetPosition(Fdecoder, BASS_ChannelSeconds2Bytes(Fdecoder, msec), BASS_POS_BYTE);
        BufLen:= Bass_ChannelGetData(Fdecoder, @PeakBuf, 10400);

        Data:= @PeakBuf;
      end;
      dec(rc);
    end;
    if (counter > High(FpeaksL)) or (counter > High(FpeaksR)) then break;
    FpeaksL[counter]:= pl;
    FpeaksR[counter]:= pr;
    inc(counter);
    pl:= 0;
    pr:= 0;
    rc:= trunc(power(2, Fzoom )); //-1
  end;

  OutputDebugString('Daten können abgeholt werden'); // ist nur für mich

  Synchronize(UpdatePeaksTh);

  //finally

  FBinfertig:= True;
  //setlength(FpeaksL, 0);
  //setlength(FpeaksR, 0);
  //FpeaksL:= nil;
  //FpeaksR:= nil;
  finalize(FpeaksL);
  finalize(FpeaksR);
    except


  on E: Exception do ErrorPop('Fehler im thread!');
  end;

  OutputDebugString('ich beende mich'); // ist nur für mich
  Terminate;

 // end;
end;					

1:
2:
3:
4:
5:
6:
7:
8:
9:
10:
11:

PeakBuf: array[0..10400] of integer;  //10400=60ms Daten //1sekunde daten = 176400
//setlength(FpeaksL, 2600);<-----entspricht 2600pixel auf 2 Monitore
//setlength(FpeaksR, 2600);<-----
if BufLen <= 0 then
begin
   msec:= msec + 0.0585;
   //FillChar(PeakBuf, sizeof(PeakBuf), 0);
   BASS_ChannelSetPosition(Fdecoder, BASS_ChannelSeconds2Bytes(Fdecoder, msec), BASS_POS_BYTE);
   BufLen:= Bass_ChannelGetData(Fdecoder, @PeakBuf, 10400);//176400<-----
  Data:= @PeakBuf;
end;					

1:
2:
3:
4:
5:
6:
7:
8:
9:
10:
11:

procedure TScanThread.UpdatePeaksTh;
begin
   try
      if Assigned(FOnUpdatePeaks) then
         FOnUpdatePeaks(Self, FpeaksL, FpeaksR);
   except
      on E: Exception do ErrorPop('fehler synchronize!'+ inttostr(high(FpeaksL)));
   end;
   
   OutputDebugString('daten lesen beendet'); // ist nur für mich
end;					

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

procedure TForm3.MyThreadUpdatePeaks(Sender: TObject; pL, pR: array of SmallInt);
var i: integer;
begin
    try
      for i:= low(pL) to high(pR) do
      begin
          wavebufL[i]:= pL[i];
          wavebufR[i]:= pR[i];
     end;
   except
      on E: Exception do ErrorPop('Fehler im Updatepeaks!');
   end;

   OutputDebugString('Daten gelesen'); // ist nur für mich
   DrawPeaks;
   formpaint(self);
end;					

1:
2:

  setlength(wavebufL, buf);
  setlength(wavebufR, buf);					

1:
2:
3:
4:
5:
6:
7:

//im onresize
NewThread:= TScanThread.Create(mychan1, xzoom, buf);
.....
.....
//im Thread.execute
setlength(FpeaksL, Fbuf);
setlength(FpeaksR, Fbuf);					

1:
2:
3:
4:
5:

      for i:= low(pL) to high(pR) do //bis 100!!!
      begin
          wavebufL[i]:= pL[i]; //BOOM
          wavebufR[i]:= pR[i];
     end;					

1:
2:
3:
4:
5:

for i:= low(pL) to high(pR) do //bis 100!!!
 begin
  wavebufL[i]:= pL[i]; //BOOM
  wavebufR[i]:= pR[i];
 end;					

1:
2:
3:
4:
5:
6:
7:
8:
9:

for i:= low(pL) to high(pL) do
 begin
  wavebufL[i]:= pL[i];
 end;

for i:= low(pR) to high(pR) do
 begin
  wavebufR[i]:= pR[i];
 end;					

1:
2:
3:
4:
5:

      for i:= low(pL) to Min(high(pR),high(wavebufL)) do //bis 100!!!
      begin
          wavebufL[i]:= pL[i]; //BOOM
          wavebufR[i]:= pR[i];
     end;					

1:
2:
3:
4:
5:
6:
7:
8:
9:
10:
11:
12:
13:
14:
15:
16:
17:
18:
19:
20:
21:
22:
23:
24:

procedure TScanThread.Execute;
var 
  PeaksL, PeaksR: array of ...;
begin
  SetLength(PeaksL, ...);
  SetLength(PeaksR, ...);

  // Mit den lokalen Variablen PeakL und PeakR arbeiten


  // Wenn du damit fertig bist in einer CriticalSection auf die Felder übertragen
  FCriticalSection.Enter;
  try
    FPeaksL := PeaksL;
    FPeaksR := PeaksR;
    PeaksL := nil;
    PeaksR := nil;
  finally
    FCriticalSection.Leave;
  end;

  Synchronize(...);

end;					

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

procedure TScanThread.UpdatePeaksTh;
begin
  if Assigned(FOnUpdatePeaks) then
  begin
    // Auch hier nur gelockt darauf zugreifen
    FCriticalSection.Enter;
    try
      FOnUpdatePeaks(Self, FPeaksL, FPeaksR);
    finally
      FCriticalSection.Leave;
    end;
  end;
end;