| Цитата(_Tanatos_ @ 30.11.2007, 15:43) | Цитата(xvr @ 30.11.2007, 14:58  ) | | Или скопируйте реализацию метода Synchronize из TThread к себе в логер |
Интересно, где ты видел реализацию этой функции?
|
В исходниках vcl
| Цитата |
А подвязывать класс журнала на VCL однозначно неправильно!!!, так как этот класс должен быть независим ни от каких библиотек кроме std
|
Тогда его клиенты должны быть готовы к тому, что их будут вызывать на любых потоках, к чему vcl не готов.
| Цитата |
Добавлено @ 15:46
ИМХО
Класс журнала должен безопасно регистрировать новое сообщение (пусть будет очередь сообщений)
Затем от должен поочередно безопасно вызвать функци OnLogAdd
Затем уже в пределах функции OnLogAdd должно быть выполнено безопасное действие про сохранению, отображению и т.д. сообщения.
|
Это зависит от того, сколько будет этих OnLogAdd. Если придется делать много разновидностей OnLogAdd с синхронизацией, то лучше ее поместить в сам логер, или сделать какой-нибдь wrapper для синхронизации
| Цитата |
Вопрос в том, что внутри метода Synchronize, может буть это можно сделать самомму в пределах функции OnLogAdd() ?
|
Посмотри сам в файле Source\vcl\classes.pas
Собственно можно сделать и проще (так было сделано в BCB 3) - Synchronize посылала спец. сообщение в handle Application, по которому та в оконной процедуре вызывала запрошенную процедуру (теперь спец. сообщения нет, а производится переодический контроль на сообщении WM_NULL)
(от BCB 6.0)
| Код |
procedure TThread.Synchronize(Method: TThreadMethod);
var
SyncProc: TSyncProc;
begin
if GetCurrentThreadID = MainThreadID then
Method
else
begin
{$IFDEF MSWINDOWS}
SyncProc.Signal := CreateEvent(nil, True, False, nil);
try
{$ENDIF}
{$IFDEF LINUX}
FillChar(SyncProc, SizeOf(SyncProc), 0); // This also initializes the cond_var
{$ENDIF}
EnterCriticalSection(ThreadLock);
try
FSynchronizeException := nil;
FMethod := Method;
SyncProc.Thread := Self;
SyncList.Add(@SyncProc);
ProcPosted := True;
if Assigned(WakeMainThread) then
WakeMainThread(Self);
{$IFDEF MSWINDOWS}
LeaveCriticalSection(ThreadLock);
try
WaitForSingleObject(SyncProc.Signal, INFINITE);
finally
EnterCriticalSection(ThreadLock);
end;
{$ENDIF}
{$IFDEF LINUX}
pthread_cond_wait(SyncProc.Signal, ThreadLock);
{$ENDIF}
finally
LeaveCriticalSection(ThreadLock);
end;
{$IFDEF MSWINDOWS}
finally
CloseHandle(SyncProc.Signal);
end;
{$ENDIF}
if Assigned(FSynchronizeException) then raise FSynchronizeException;
end;
end;
type
TSyncProc = record
Thread: TThread;
{$IFDEF MSWINDOWS}
Signal: THandle;
{$ENDIF}
{$IFDEF LINUX}
Signal: TCondVar;
{$ENDIF}
end;
PSyncProc = ^TSyncProc;
var
ProcPosted: Boolean;
SyncList: TList = nil;
function CheckSynchronize: Boolean;
var
SyncProc: PSyncProc;
begin
if GetCurrentThreadID <> MainThreadID then
raise EThread.CreateResFmt(@SCheckSynchronizeError, [GetCurrentThreadID]);
if ProcPosted then
begin
EnterCriticalSection(ThreadLock);
try
Result := (SyncList <> nil) and (SyncList.Count > 0);
if Result then
begin
while SyncList.Count > 0 do
begin
SyncProc := SyncList[0];
SyncList.Delete(0);
try
SyncProc.Thread.FMethod;
except
SyncProc.Thread.FSynchronizeException := AcquireExceptionObject;
end;
{$IFDEF MSWINDOWS}
SetEvent(SyncProc.signal);
{$ENDIF}
{$IFDEF LINUX}
pthread_cond_signal(SyncProc.Signal);
{$ENDIF}
end;
ProcPosted := False;
end;
finally
LeaveCriticalSection(ThreadLock);
end;
end else Result := False;
end;
{ Call CheckSynchronize periodically within the main thread in order for
background threads to synchronize execution with the main thread. This
is mainly for applications that have an event driven UI such as Windows
or XWindows (Qt/CLX). The best place this can be called is during Idle
processing. This guarantees that the main thread is in a known "good"
state so that method calls can be safely made. Returns True if a method
was synchronized. Returns False if there was nothing done.
}
function CheckSynchronize: Boolean;
{ Assign a method to WakeMainThread in order to properly force an event into
the GUI thread's queue. This will make sure that non-GUI threads can quickly
synchronize with the GUI thread even if no events are being processed due to
an idle state }
var
WakeMainThread: TNotifyEvent = nil;
procedure TApplication.WndProc(var Message: TMessage);
...
begin
...
with Message do
case Msg of
...
WM_NULL:
CheckSynchronize;
...
end;
...
end;
|
|
