Groups | Search | Server Info | Keyboard shortcuts | Login | Register [http] [https] [nntp] [nntps]

Groups > comp.programming.threads > #1138

My threadpool engine and scalability...

Cross-posted to 2 groups.

Show all headers | View raw

Hello,

If you take a look at my threadpool engine:

http://pages.videotron.com/aminer/

you will notice that it does not scale in the execute() method
cause LockedIncLong(balance1) is expensive.

here is the execute method:

==

function TThreadPool.execute(func:TMyProc;const Context: Pointer): Boolean;

var
local_balance,local_count:long;

params:  PParams;
p:pointer;

begin
new(params);
setlength(params^,1);
params^[0].proc:=func;
params^[0].data:=context;

local_balance:=LockedIncLong(balance1) mod FThreadCount;
while not Queues[local_balance].push(tobject(params))  do sleep(0);
events[local_balance].setevent;
end;

===

Now to be able to scale the execute() method we have to add a getindex()
method like this

function TThreadPool.getindex(var index:long);
begin
 if  index <> 0
 then
  begin
   inc(index);
    index:=index mod FThreadCount;
 end;
end;


and  also  add an execute1() method that scales perfectly like this:

==
function TThreadPool.execute1(func:TMyProc;const Context:
Pointer;index:long): Boolean;

var
local_balance,local_count:long;

params:  PParams;
p:pointer;

begin
new(params);
setlength(params^,1);
params^[0].proc:=func;
params^[0].data:=context;

while not Queues[index].push(tobject(params))  do sleep(0);
events[local_balance].setevent;
end;

==

so we have to call the getindex() method from mutiple threads like this:

// we have to initialize count to zero before:

getindex(count)
ThreadPool.execute(myproc,data,count)

and now the execute1() method will scale perfectly.


I will try update my threadpol engine soon.



Thank you,
Amine Moulay Ramdane.

Back to comp.programming.threads | Previous | Next — Next in thread | Find similar

Thread

My threadpool engine and scalability... "aminer" <aminer@videotron.ca> - 2012-10-01 11:51 -0500
  Re: My threadpool engine and scalability... "aminer" <aminer@videotron.ca> - 2012-10-01 11:54 -0500
  Re: My threadpool engine and scalability... "aminer" <aminer@videotron.ca> - 2012-10-01 12:06 -0500
  Re: My threadpool engine and scalability... "aminer" <aminer@videotron.ca> - 2012-10-01 12:18 -0500
  Re: My threadpool engine and scalability... "aminer" <aminer@videotron.ca> - 2012-10-01 12:30 -0500
  Re: My threadpool engine and scalability... "aminer" <aminer@videotron.ca> - 2012-10-01 12:36 -0500
  Re: My threadpool engine and scalability... "aminer" <aminer@videotron.ca> - 2012-10-01 12:43 -0500

csiph-web