freepascal.ru

При помощи пула из M потоков (M ≤ N), используя системный пул потоков или асинхронные потоки ввода/вывода.

При помощи массива из M потоков (M ≤ N), используя для синхронизации объект ядра — семафор.

В API Windows пула потоков, как такового, нет. Для создания пула рабочих потоков можно вручную создавать массив потоков вызовом функции CreateThread, а затем ожидать окончания их выполнения вызовом функции WaitForMultipleObjects(Ex) или MsgWaitForMultipleObjects(Ex). Для создания очереди асинхронных операций используется функция QueueUserAPC. В качестве сигнальных объектов могут выступать как сами процессы и потоки, так и семафоры, мьютексы, таймеры и события (табл. 3.5, п. 3.2.3). Также для организации пула потоков можно использовать порты завершения ввода/вывода (п. 3.2.3.5).

stesl писал(а):Как?

stesl писал(а):Может есть желание мозг поднапречь? Моя беда, то, что я не знаю языки.

stesl писал(а):Так есть у кого то опыт организации такого пула? Может есть желание мозг поднапречь? Моя беда, то, что я не знаю языки. От англ до С. И не могу пользоваться примерами написанными на С.

Дож писал(а):исчерпывающе отвечает на вопрос о том, как делать. В чём трудности?

Pavia писал(а):А задача где? Прочтите в интернете как правильно задавать вопросы. Не описывайте что делали или что сделали описывайте что надо сделать. Иначе вас непонятно.

runewalsh писал(а):Есть. :\

runewalsh писал(а): В методичке полно неверной информации, как посмотрю («иногда система инвертирует приоритеты, чтобы разрешить конфликты типа deadlock»).

serbod писал(а):Зачем тебе теория вычислительных процессов, если языки не знаешь и знать не хочешь? Иди руками работай.

olegy123 писал(а):В паскале называется это все Parallel programming

Цитата говорит, что можно создать псевдопул, т.е. массив.

Но как им управлять?

FP знает QueueUserAPC?

Дож писал(а):Массив — это один из способов реализовать пул (любой пул, а только потоков). Почему получится «псевдопул», а не обычный пул, я не очень понимаю.

Дож писал(а):Вы не назвали какие операции с пулом вам нужны, поэтому лучший ответ на этот вопрос — легко и непринуждённо

Дож писал(а):Из FP можно объявить и вызвать любую WinApi функцию.

Код: Выделить всё

uses
  windows;

function QueueUserAPC(pfnAPC: Pointer; hThread: HANDLE; dwData: ULONG_PTR): DWORD; stdcall; external 'Kernel32.dll';

begin
  Writeln(QueueUserAPC(nil, 0, 0));
end.


Код: Выделить всё

D:\data\temp>fpc tp.pas
Free Pascal Compiler version 3.0.4 [2017/10/06] for i386
Copyright (c) 1993-2017 by Florian Klaempfl and others
Target OS: Win32 for i386
Compiling tp.pas
Linking tp.exe
8 lines compiled, 0.3 sec, 25424 bytes code, 1268 bytes data

stesl писал(а):Или экстернал - длл и говорит о том, что это системная ф-ция

Снег Север писал(а):Именно это и говорит - вызвать функцию из системной библиотеки Kernel32.dll

stesl писал(а):В какой методичке?

Код: Выделить всё

{$mode objfpc} {$h+}
uses
   Windows, SysUtils;

   function QueueUserWorkItem(func: LPTHREAD_START_ROUTINE; Context: pointer; Flags: ULONG): BOOL; stdcall; external kernel32;

var
   runningTasks: integer; // = 0
   allTasksCompleted: PRTLEvent;

   procedure PrepareTaskQueuing;
   begin
      if InterlockedIncrement(runningTasks) = 1 then RTLEventResetEvent(allTasksCompleted);
   end;

   procedure NoteTaskCompleted;
   begin
      if InterlockedDecrement(runningTasks) = 0 then RTLEventSetEvent(allTasksCompleted);
   end;

   procedure Task(param: pointer); stdcall;
   begin
      writeln('Задача ' + IntToStr(PtrUint(param)) + ' начата (поток #' + IntToStr(GetCurrentThreadID) + ')');
      Sleep(1500);
      writeln('Задача ' + IntToStr(PtrUint(param)) + ' выполнена (поток #' + IntToStr(GetCurrentThreadID) + ')');
      NoteTaskCompleted;
   end;

begin
   allTasksCompleted := RTLEventCreate;
   PrepareTaskQueuing; writeln('Добавление задачи 1.'); QueueUserWorkItem(@Task, pointer(1), 0);
   Sleep(1000);
   PrepareTaskQueuing; writeln(LineEnding + 'Добавление задачи 2.'); QueueUserWorkItem(@Task, pointer(2), 0);
   Sleep(1000);
   PrepareTaskQueuing; writeln(LineEnding + 'Добавление задачи 3.'); QueueUserWorkItem(@Task, pointer(3), 0);
   Sleep(1000);
   PrepareTaskQueuing; writeln(LineEnding + 'Добавление задачи 4.'); QueueUserWorkItem(@Task, pointer(4), 0);

   writeln(LineEnding + 'Ожидание завершения всех задач...');
   RTLEventWaitFor(allTasksCompleted);
   RTLEventDestroy(allTasksCompleted);
   writeln('OK!');
   readln;
end.

Друг, а ты не мог бы по полочкам разложить, что за параметры у этой ф-ции, msdn написан на англ и С.

Код: Выделить всё

procedure APCProc(dwParam: ULONG_PTR); stdcall;
begin
  // тут код
end;

Почему ты ее вызываешь как то интересно через writeln.

Что там за кернел.

Ты спросишь, а какого ты вообще про эту ф-цию спрашиваешь?

И вообще, что делать дальше?

Что мы получаем в рез-тате вызова этой ф-ции?