Мониторинг изменений на USB (многопоточность)

[admigator]

Привет всем!
На просторах форумов накопал две программки:

1- определяет подключения USB накопителей в систему (и не только ) (setupAPI.pas)
2- мониторит изменения в папке (wfsU.pas)

Попробовал соединить их вместе. Получилось. Только вылезла одна особенность. Во втором модуле используються потоки, а именно процедурой

procedure StartWatch(pName: string; pFilter: cardinal; pSubTree: boolean; pInfoCallBack: TWatchFileSystemCallBack);

создается поток, который и мониторит изменения в папке.

А сама функция создает обьект - екземпляр класса TWFS

procedure StartWatch(pName: string; pFilter: cardinal; pSubTree: boolean; pInfoCallBack: TWatchFileSystemCallBack);
begin

 WFS:=TWFS.Create(pName, pFilter, pSubTree, pInfoCallBack);
 //th_no=th_no+1;
end;

А вот собственно сам класс(обьявление)

 TWFS = class(TThread)
  private
    FName           : string;
    FFilter         : Cardinal;
    FSubTree        : boolean;
    FInfoCallBack   : TWatchFileSystemCallBack;
    FWatchHandle    : THandle;
    FWatchBuf       : array[0..4096] of Byte;
    FOverLapp       : TOverlapped;
    FPOverLapp      : POverlapped;
    FBytesWritte    : DWORD;
    FCompletionPort : THandle;
    FNumBytes       : Cardinal;
    FOldFileName    : string;
    function CreateDirHandle(aDir: string): THandle;
    procedure WatchEvent;
    procedure HandleEvent;
  protected
    procedure Execute; override;
  public
    constructor Create(pName: string; pFilter: cardinal; pSubTree: boolean; pInfoCallBack: TWatchFileSystemCallBack);
    destructor Destroy; override;
  end;

Монитор изменения на дисках работает нармально. Если вставляю две флешки, тоже все ок. Проблемма при извлечении. На кнопку "извлечь" выполняю процедуру StopWatch

она делает следущее:

procedure StopWatch
var
  Temp : TWFS;
begin
  if Assigned(WFS) then
  begin
   PostQueuedCompletionStatus(WFS.FCompletionPort, 0, 0, nil);
   Temp := WFS;
   WFS:=nil;
   Temp.Terminate;
  end;
end;

т.е. останавливает поток и "убивает" обьект WFS. Но останавливает только последний поток. А первый остается.

Вопрос. Как остановить первый поток. И в случае трех флешек при извлечении останавливать нужный поток.
Спасибо.
В атачче исходники.

[xoodoo]

Ссылки на созданные объекты-потоки записывай в отдельные элементы заранее подготовленного массива, а не в одну и ту же глобальную переменную WPS.

[admigator]

Пробую так
в глобальных переменных
вместо

var
 WFS : TWFS;

ставлю

var
  ArrWFS : array of TWFS = nil;
  Thread_counter: integer = 0;

потом

procedure StartWatch(pName: string; pFilter: cardinal; pSubTree: boolean; pInfoCallBack: TWatchFileSystemCallBack);
begin
 ArrWFS[Thread_counter]:=TWFS.Create(pName, pFilter, pSubTree, pInfoCallBack);
 Thread_counter:=Thread_counter+1;
end;

ошибка в конструкторе после Resume "Access violation at adress 0045E27D in vodule 'Project1.exe' Write of adress 00000000"

constructor TWFS.Create(pName: string; pFilter: cardinal;
  pSubTree: boolean; pInfoCallBack: TWatchFileSystemCallBack);
begin
  inherited Create(True);
  FreeOnTerminate:=True;
  FName:=IncludeTrailingBackslash(pName);
  FFilter:=pFilter;
  FSubTree:=pSubTree;
  FOldFileName:=EmptyStr;
  ZeroMemory(@FOverLapp, SizeOf(TOverLapped));
  FPOverLapp:=@FOverLapp;
  ZeroMemory(@FWatchBuf, SizeOf(FWatchBuf));
  FInfoCallBack:=pInfoCallBack;
  Resume
end;

пробую использовать TList

var
FThreads: TList;

procedure StartWatch(pName: string; pFilter: cardinal; pSubTree: boolean; pInfoCallBack: TWatchFileSystemCallBack);
begin
  FThreads := TList.Create;
  WFS:=TWFS.Create(pName, pFilter, pSubTree, pInfoCallBack);
  FThreads.Add(WFS);
end;

но не пойму как мне из этого списка потом получить поток соответствующий моей флешке.

[xoodoo]

Ты взялся за не самые тривиальную технологию - мультипоточность, не зная даже азов.

ошибка в конструкторе после Resume

Да не в конструкторе она)

Ты пытаешься присвоить некое значение (неважно какое, в дан.случае - ссылку на экземпляр созданного объекта-потока) несуществующему элементу массива.

пробую использовать TList

Те же грабли - при каждом вызове StartWatch() ты затираешь значение поля FTreads, безвозвратно теряя в памяти предудущий объект-список (на который ссылалось поле после предыдущего вызова StartWatch).

как мне из этого списка потом получить поток соответствующий

У тебя же каждый создаваемый объект-поток именован, причем уникально как можно предположить.
Т.е. каждый поток имеет уникальный строковый атрибут - имя.
Прямо-таки напрашивается простейшее решение - TStringList. Каждый элемент этого списка способен хранить строку и ассоццированный с этой строкой указатель. Значению указателя можно присвоить ссылку на объект-поток, которую возвращает конструктор TWPS. Далее при вызове StopWatch найти соотв.элемент списка по имени потока и получить ссылку на этот поток не составляет никакой сложности.

[admigator]

Сообщение от xoodoo

Ты взялся за не самые тривиальную технологию - мультипоточность, не зная даже азов.

Таки да :-(

Прямо-таки напрашивается простейшее решение - TStringList. Каждый элемент этого списка способен хранить строку и ассоццированный с этой строкой указатель. Значению указателя можно присвоить ссылку на объект-поток, которую возвращает конструктор TWPS. Далее при вызове StopWatch найти соотв.элемент списка по имени потока и получить ссылку на этот поток не составляет никакой сложности.

Не хватает опыта чтоб такое написать. В Delphi лет 8 назад сидел. А тут такая задача. Если будет время написать в виде кода. Спасибо