Mandar trabajos a distintos procesadores.

[matabyte]

Buenos días, soy nuevo en el foro pero no programando. Empecé con Turbo Pascal 6 y ahora disfruto programando en "Delphi 2007". Ya he programado aplicaciones bastante grandes, y ahora me encuentro con un problema y no he conseguido encontrar información por Internet.

Antes dejaba a windows elegir por donde iban los hilos (threads) de mis aplicaciones, pero ahora estoy haciendo una aplicación de uso intensivo de CPU y me gustaría saber si sabrían como mandar trabajos (o threads), para que se ejecuten en distintas CPUs.

Pensaba en algo al estilo:

Código Delphi [-]
  Thread_Lectura.execute(CPU1);
  Thread_Calculo.execute(CPU2);

Igual es imposible esto que pido con delphi, pero por intentarlo... Un saludo y gracias por adelantado

[[cHackAll]]

Lo que pides es aplicable a procesos; no a hilos.

Saludos

[jachguate]

No puede hacerse de la manera que lo describís, pero si puede hacerse.

Cada hilo puede tener una mascara de afinidad con CPU's diferente. El sistema utiliza esa mascara para asignar los hilos con diferentes cpu's.

Esta mascara se establece llamando a la función SetThreadAffinityMask, declarada en la unidad Windows.

En delphi3000, encontré este artículo, que te provee de una clase que ya encapsula esto en una propiedad.

Código Delphi [-]
unit ExThread;

interface

uses
  Classes;

type
  TExThread = class(TThread)
  private
    FAffinityMask: DWord;
    procedure SetAffinity(const Value: DWord);
    { Private declarations }
  protected
    procedure Execute; override;
  public
    property AffinityMask : DWord read FAffinityMask write SetAffinity;
  end;

implementation

{ Important: Methods and properties of objects in VCL can only be used in a
  method called using Synchronize, for example,

      Synchronize(UpdateCaption);

  and UpdateCaption could look like,

    procedure TExThread.UpdateCaption;
    begin
      Form1.Caption := 'Updated in a thread';
    end; }

{ TExThread }

procedure TExThread.Execute;
begin
  { Place thread code here }
end;

procedure TExThread.SetAffinity(const Value: DWord);
begin
  FAffinityMask := SetThreadAffinityMask(Handle,Value);
  if FAffinityMask = 0 then raise Exception.Create('Error setting thread affinity mask : ' + IntToStr(GetLastError));
end;

end.

La mascara de afinidad, es un mapa de bits, donde el bit 1 se corresponde con el cpu 0

así, si queres que un hilo se ejecute solamente en el cpu 3 (de una core 2 quad, por ejemplo), la mascara de afinidad será $8 (en delphi) o 0x8 (en c).

Hasta luego.

[[cHackAll]]

Hufff; muy cierto amigo jachguate, yo solo reconocía a SetProcessAffinityMask y había dejado a un "lado" a SetThreadAffinityMask.

Saludos

[matabyte]

Muchas gracias por la respuesta!.

Es lo que necesitaba, mandar Threads distintos a CPUs distintas. Me imaginaba que Delphi tendría algo para poder manejar los Threads a las CPUs, pero no lo encontraba.

Muchas gracias de nuevo.

PD: Por cierto, no sabréis si existe en Delphi alguna función para saber el número de CPUs existentes?

[mamcx]

Sin embargo, ten en cuenta que Windows, asi como cualquier OS, tiene un algoritmo de asignacion de cargas que muy probablemente sea mas listo que lo que uno haga.

Lo unico que se me ocurre que podria servir es siempre mandar a procesadores >1. Pero no he hecho pruebas para demostrar si seria mejor asi o que....

[jachguate]

Empezado por matabyte

PD: Por cierto, no sabréis si existe en Delphi alguna función para saber el número de CPUs existentes?

¡claro!: cpu count en delphi.

Te recomiendo preguntarle también a google, que regularmente da buenas respuestas!

Hasta luego.