unit UnitImageConvertor;

interface


uses
  System.SysUtils,
  System.Classes,
  System.Threading,
  System.SyncObjs,
  System.Math,
  Vcl.Imaging.jpeg,
  Vcl.Graphics,
  Vcl.Imaging.pngimage,
  Vcl.FileCtrl,
  Vcl.Forms;


type
  TArrayNameFile = array of string;
  TThreadImage = class(TThread)
  protected
{$IFDEF TTREAD}
  procedure Execute; override;
{$ENDIF}
  end;

type
  TMyClass = class(TObject);
  //private
  //FResult: Int64;

{$IFDEF TASK}
procedure RunParalel(const AArraySourceNameFile, AArrayFinishNameFile:TArrayNameFile;
  const ALengthArray: Integer);
{$ENDIF}

{$IFDEF TTREAD}
procedure RunThread(const AArraySourceNameFile, AArrayFinishNameFile: TArrayNameFile;
  const ALengthArray: Integer);
{$ENDIF}


function LoadImageFromFile(const ASourceNameFile: PChar): THandle;
procedure SaveImageToFile(const AImageHandle: THandle; AFinishNameFile: PChar);
procedure FreeImage(const AImageHandle: THandle);




var
  ArrayThread: array [0..16] of TThreadImage;
{ENDIF TASK}

implementation



uses
  FiveProgect;

{$IFDEF TTREAD}
var

  PositionThread, LengthArray, ExitThread: Integer;
  ArrayOldNameFile, ArrayNewNameFile: array of string;
  MyObject: TMyClass;
  CriticalSectionThread: TCriticalSection;


procedure RunThread(const AArraySourceNameFile, AArrayFinishNameFile: TArrayNameFile;
  const ALengthArray: Integer);
var
  I, CountTthread: Integer;
begin
  LengthArray := ALengthArray;
  PositionThread := 0;
  Form1.ProgressBarConvert.Max := ALengthArray;
  Form1.ProgressBarConvert.Position := 0;
  SetLength(ArrayOldNameFile, ALengthArray);
  SetLength(ArrayNewNameFile, ALengthArray);
  ExitThread := 0;

  for I := 0 to LengthArray - 1 do
  begin
    ArrayOldNameFile[I] := AArraySourceNameFile[I];
    ArrayNewNameFile[I] := AArrayFinishNameFile[I];
  end;

  CriticalSectionThread := TCriticalSection.Create;
  CountTthread := 2 * System.CPUCount;

  for I := 0 to CountTthread - 1 do
  begin
    ArrayThread[I] := TThreadImage.Create(True);
    ArrayThread[I].Priority := tpNormal;
  end;

  For I := 0 to CountTthread - 1 do
  begin
    ArrayThread[I].Start;
  end;

  while True do
  begin
    if ExitThread < ALengthArray then
    sleep(3000)
    else
    begin
      CriticalSectionThread.Free;
      Exit
    end;
  end;

end;
{$ENDIF}

function LoadImageFromFile(const ASourceNameFile: PChar): THandle;
var
  LBmpFile: TBitmap;
  LJPEGFile: TJPEGImage;
  LPngFile: TPNGObject;

begin
  LBmpFile := TBitmap.Create;

  if AnsiUpperCase(ExtractFileExt(string(ASourceNameFile))) = '.BMP' then
  begin
    try
      LBmpFile.LoadFromFile(string(ASourceNameFile));
      Result := THandle(LBmpFile);
    finally
    end;
  end
  else if (AnsiUpperCase(ExtractFileExt(string(ASourceNameFile))) = '.JPG') then
  begin
    LJPEGFile := TJPEGImage.Create;
    try
      LJPEGFile.CompressionQuality := 100;
      LJPEGFile.LoadFromFile(string(ASourceNameFile));
      LBmpFile.Assign(LJPEGFile);
      Result := THandle(LBmpFile);
    finally
      LJPEGFile.Free;
    end;
  end
  else if (AnsiUpperCase(ExtractFileExt(ASourceNameFile)) = '.PNG') then
  begin
    LPngFile := TPNGObject.Create;
    try
      LPngFile.LoadFromFile(ASourceNameFile);
      LBmpFile.Assign(LPngFile);
      Result := THandle(LBmpFile);
    finally
      LPngFile.Free;
    end;
  end;

end;

procedure SaveImageToFile(const AImageHandle: THandle; AFinishNameFile: PChar);
var
  LBmpFileSource: TBitmap;
  LJPEGFile: TJPEGImage;
  LPngFile: TPNGObject;
begin
  LBmpFileSource := TBitmap(AImageHandle);
  if AnsiUpperCase(ExtractFileExt(AFinishNameFile)) = '.BMP' then
  begin
  LBmpFileSource.SaveToFile(AFinishNameFile)
  end
  else if AnsiUpperCase(ExtractFileExt(AFinishNameFile)) = '.JPG' then
  begin
    LJPEGFile := TJPEGImage.Create;

    try
      LJPEGFile.Assign(LBmpFileSource);
      LJPEGFile.SaveToFile(AFinishNameFile);
    finally
      LJPEGFile.Free;
    end;

  end
  else if AnsiUpperCase(ExtractFileExt(AFinishNameFile)) = '.PNG' then
  begin
    LPngFile := TPNGObject.Create;

      try
        LPngFile.Assign(LBmpFileSource);
        LPngFile.SaveToFile(AFinishNameFile);
      finally
        LPngFile.Free;
      end;

  end;
end;

procedure FreeImage(const AImageHandle: THandle);
begin
  TObject(AImageHandle).Free;

end;

{$IFDEF TASK}

procedure RunParalel(const AArraySourceNameFile, AArrayFinishNameFile: TArrayNameFile;
  const ALengthArray: Integer);
var
  LHandleImage: THandle;
  Task: ITask;
  I1: integer;

begin
  I1 := 0;
  Form1.ProgressBarConvert.Max := ALengthArray;
  Form1.ProgressBarConvert.Position := 0;


  TParallel.For(0,  ALengthArray-1, procedure(I : integer)
    var
      FileName: string;
    begin

     //
      FileName := AArraySourceNameFile[i];
      LHandleImage:= LoadImageFromFile(Pchar(FileName));

      if LHandleImage > 0 then
      begin
        SaveImageToFile(LHandleImage, PChar(AArrayFinishNameFile[i]));
        //Position := I;
        TThread.Queue(nil,
        procedure
        begin
          Form1.ProgressBarConvert.Position := Form1.ProgressBarConvert.Position + 1;
          Application.ProcessMessages;
        end);
        //PositionProgressBar
      end;


    end
   );


end;


{$ENDIF}

{$IFDEF TTREAD}

{ TMyThread }

procedure TThreadImage.Execute;
var
  LImageHandle: THandle;
  I: Integer;
begin
  inherited;

  while PositionThread < LengthArray do
  begin
    CriticalSectionThread.Enter;
      PositionThread := PositionThread + 1;
      I := PositionThread - 1;
    CriticalSectionThread.Leave;
    LImageHandle := LoadImageFromFile(PChar(ArrayOldNameFile[I]));
    SaveImageToFile(LImageHandle, PChar(ArrayNewNameFile[I]));
    FreeImage(LImageHandle);

    Synchronize(procedure
    begin
      Form1.ProgressBarConvert.Position := Form1.ProgressBarConvert.Position + 1;
    end);
   CriticalSectionThread.Enter;
      ExitThread := ExitThread + 1;
   CriticalSectionThread.Leave;
  end;

  Exit;
end;
{$ENDIF}


end.