مشکل در کارکردن با thread ها

[p_ooya]

سلام به همه.
من در برنامه ام باید به یه بانک راه دور remote کانکت بشم و چند تا کوئری روش بگیرم. چون اتصال به بانک روی هاست و اجرای پرس و جو ها طول میکشه یه فرم خوشامد گذاشتم که در پیش زمینه اش، اتصال و کوئری ها انجام بشه. برای اینکه فرم خوشامد قفل نشه از یه thread استفاده کردم. مشکل اینجاست که با وجود استفاده از thread باز هم فرم قفل میشه و بعد از اینکه اتصال برقرار شد از حالت قفل خارج میشه. من کدی رو که نوشتم قرار میدم :

کد thread :

unit Unit12;



interface

uses

  classes,stdctrls,sysutils,Myclasses, Mycall, windows;



type

  InitializeThread = class(TThread)

  private

    i:integer;

    ss:string;

    procedure setlabel;

    procedure localdbconnect;

    procedure hostdbconnect;

    procedure settingvalues;

    procedure settingqueries;

    procedure logingin;



  public

     //------------

  protected

    procedure execute; override;



end;



implementation



uses unit1,unit2,unit3,unit4, unit13;

//-------------------------------------------------------------------

procedure InitializeThread.setlabel;

begin

  WelcomeForm.LabelStatus.Caption:=ss;

end;

//-------------------------------------------------------------------

procedure InitializeThread.settingvalues;

begin



    DataModule1.MyConnection_Host.Database:=LoginForm.  sEdit4.Text;

    DataModule1.MyConnection_Host.Password:=LoginForm.  sEdit6.Text;

    DataModule1.MyConnection_Host.Username:=LoginForm.  sEdit5.Text;

    DataModule1.MyConnection_Host.Server:=LoginForm.sE  dit3.Text;



    DataModule1.MyConnection_Local.Database:=LoginForm  .sEdit8.Text;

    DataModule1.MyConnection_Local.Password:=LoginForm  .sEdit10.Text;

    DataModule1.MyConnection_Local.Username:=LoginForm  .sEdit9.Text;

    DataModule1.MyConnection_Local.Server:=LoginForm.s  Edit7.Text;

end;

//-------------------------------------------------------------------

procedure InitializeThread.localdbconnect;

begin



      try

        DataModule1.MyConnection_Local.Connect;

      except

        on e:EMyError do

          begin

             if e.ErrorCode = 1045 then MessageBox(Handle,'.äÇã ˜ÇÑÈÑí íÇ ˜áãå ÚÈæÑ Ïæã ÇÔÊÈÇå ÇÓÊ','!ÎØÇ',MB_OK+MB_ICONERROR);

             if e.ErrorCode = 2003 then MessageBox(Handle,'.ÂÏÑÓ íÇ äÇã ÓÑæÑ Ïæã ÇÔÊÈÇå ÇÓÊ','!ÎØÇ',MB_OK+MB_ICONERROR);

             if e.ErrorCode = 1049 then MessageBox(Handle,'.äÇã ÈÇä˜ ÇØáÇÚÇÊí Ïæã ÇÔÊÈÇå ÇÓÊ','!ÎØÇ',MB_OK+MB_ICONERROR);

             if e.ErrorCode = 2013 then MessageBox(Handle,'.ÊáÇÔ ÈÑÇí ÇÑÊÈÇØ ÈÇ ÓÑæÑ Ïæã ÈíÔ ÇÒ ÍÏ ãÞÑÑ Èå Øæá ÇäÌÇãíÏ','!ÎØÇ',MB_OK+MB_ICONERROR);

          end;

      end; //local except



end;

//-------------------------------------------------------------------

procedure InitializeThread.hostdbconnect;

begin



      try

        DataModule1.MyConnection_Host.Connect;

      except

        on e:EMyError do

          begin

             if e.ErrorCode = 1045 then MessageBox(Handle,'.äÇã ˜ÇÑÈÑí íÇ ˜áãå ÚÈæÑ Çæá ÇÔÊÈÇå ÇÓÊ','!ÎØÇ',MB_OK+MB_ICONERROR);

             if e.ErrorCode = 2003 then MessageBox(Handle,'.ÂÏÑÓ íÇ äÇã ÓÑæÑ Çæá ÇÔÊÈÇå ÇÓÊ','!ÎØÇ',MB_OK+MB_ICONERROR);

             if e.ErrorCode = 1049 then MessageBox(Handle,'.äÇã ÈÇä˜ ÇØáÇÚÇÊí Çæá ÇÔÊÈÇå ÇÓÊ','!ÎØÇ',MB_OK+MB_ICONERROR);

             if e.ErrorCode = 2013 then MessageBox(Handle,'.ÊáÇÔ ÈÑÇí ÇÑÊÈÇØ ÈÇ ÓÑæÑ Çæá ÈíÔ ÇÒ ÍÏ ãÞÑÑ Èå Øæá ÇäÌÇãíÏ','!ÎØÇ',MB_OK+MB_ICONERROR);

          end;

      end; //host except



end;

//-------------------------------------------------------------------

procedure InitializeThread.settingqueries;

begin

  DataModule1.MyQuery_Local1.Close;

  DataModule1.MyQuery_Local1.SQL.Text:='select count(*) as row_c_l from products';

  DataModule1.MyQuery_Local1.Open;



  DataModule1.MyQuery_Host1.Close;

  DataModule1.MyQuery_Host1.SQL.Text:='select count(*) as row_c_h from products';

  DataModule1.MyQuery_Host1.Open;



 { if DataModule1.MyQuery_Local1.FieldValues['row_c_l']=DataModule1.MyQuery_Host1.FieldValues['row_c_h'] then

     ShowMessage('equal') else ShowMessage('unequal');

  }



end;

//-------------------------------------------------------------------

procedure InitializeThread.logingin;

var

  password:String;

begin

  if DataModule1.MyConnection_Host.Connected=true then

  begin

  DataModule1.MyQuery_Host1.Close;

  DataModule1.MyQuery_Host1.SQL.Text:=('select * from users where username='''+LoginForm.sEdit1.Text+'''');

  DataModule1.MyQuery_Host1.Active:=true;

        if DataModule1.MyQuery_Host1.RecordCount>0 then

        password:=DataModule1.MyQuery_Host1.FieldValues['password'] else MessageBox(Handle,'.äÇã ˜ÇÑÈÑí íÇ ˜áãå ÚÈæÑ ÇÔÊÈÇå ÇÓÊ','!ÎØÇ',MB_OK+MB_ICONERROR);

          if password=LoginForm.sEdit2.Text then

          begin

          user_rights:=IntToBin(DataModule1.MyQuery_Host1.Fi  eldValues['privileges'],24);

          user_fullname:=DataModule1.MyQuery_Host1.FieldValu  es['full_name'];

          MainForm.Show;

          end else MessageBox(Handle,'.äÇã ˜ÇÑÈÑí íÇ ˜áãå ÚÈæÑ ÇÔÊÈÇå ÇÓÊ','!ÎØÇ',MB_OK+MB_ICONERROR);

  end // outer if





    else if DataModule1.MyConnection_Local.Connected=true then

    begin

    DataModule1.MyQuery_Local1.Close;

    DataModule1.MyQuery_Local1.SQL.Text:=('select * from users where username='''+LoginForm.sEdit1.Text+'''');

    DataModule1.MyQuery_Local1.Active:=true;

          if DataModule1.MyQuery_Local1.RecordCount>0 then

          password:=DataModule1.MyQuery_Local1.FieldValues['password'] else MessageBox(Handle,'.äÇã ˜ÇÑÈÑí íÇ ˜áãå ÚÈæÑ ÇÔÊÈÇå ÇÓÊ','!ÎØÇ',MB_OK+MB_ICONERROR);

            if password=LoginForm.sEdit2.Text then

            begin

            user_rights:=IntToBin(DataModule1.MyQuery_Local1.F  ieldValues['privileges'],24);

            user_fullname:=DataModule1.MyQuery_Local1.FieldVal  ues['full_name'];

            MainForm.Show;

            end else MessageBox(Handle,'.äÇã ˜ÇÑÈÑí íÇ ˜áãå ÚÈæÑ ÇÔÊÈÇå ÇÓÊ','!ÎØÇ',MB_OK+MB_ICONERROR);

    

    end //inner if

      else

      begin

      MessageBox(Handle,'.äÇã ˜ÇÑÈÑí íÇ ˜áãå ÚÈæÑ ÇÔÊÈÇå ÇÓÊ','!ÎØÇ',MB_OK+MB_ICONERROR);

      end; //else



end;

//-------------------------------------------------------------------

procedure InitializeThread.execute;

begin

    ss:='Setting databases connection values.';

    Synchronize(setlabel);

    Synchronize(settingvalues);



    ss:='Connecting local database...';

    Synchronize(setlabel);

    Synchronize(localdbconnect);



    ss:='Connecting host database...';

    Synchronize(setlabel);

    Synchronize(hostdbconnect);



    ss:='Comparing local and remote databases...';

    Synchronize(setlabel);

    if ((DataModule1.MyConnection_Local.Connected=true) and (DataModule1.MyConnection_Host.Connected=true)) then

    Synchronize(settingqueries);



    if ((DataModule1.MyConnection_Local.Connected=true) or (DataModule1.MyConnection_Host.Connected=true)) then

    Synchronize(logingin);



    Terminate;

    Exit;



end;

//-------------------------------------------------------------------



end.

کد فراخوانی این thread هم اینه :

procedure TLoginForm.sBitBtn1Click(Sender: TObject);

var

  myTH : InitializeThread;

begin

WelcomeForm.Show;



  try

    myTH:=InitializeThread.Create(true);

    myTH.FreeOnTerminate:=true;

    myTH.Resume;

  except

    on e:Exception do ShowMessage(e.Message);

  end;



end;

درمورد کارایی کد مشکلی ندارم و هم اتصال بدون مشکل انجام میشه و تنها مشکل قفل شدن فرمه. اشتباه من کجاست؟

پیشاپیش از راهنمایی شما متشکرم.

[tdkhakpur]

سلام
فکر کنم کد زیر را حذف کنید حل بشه.

 

  myTH.Resume;

[p_ooya]

سلام
فکر کنم کد زیر را حذف کنید حل بشه.

 

  myTH.Resume;

ممنون از توجهتون. اما (ضمن عرض احترام) فکر می کنم اینطور نیست! دو خط بالاتر از همون کدی که شما میگید، سازنده کلاس با رگومان true فراخوانی شده. این یعنی thread بعد از ساخته شدن اجرا نمیشه تا وقتی تابع resume فراخوانی بشه. منبع :

http://www.barnamenevis.org/sh...ad.php?t=79463

[tdkhakpur]

سلام
من کاری به منابع ندارم ولی شما وقتی یک ترد را create میکنید اعلام true به ترد میگوید که شروع به اجرا کند.
و resum هم به معنای اجرای مجدد هست.(من به این خاطر نظر دادم که شما گفتید فرم شما که بوسیله ترد اجرا و کنترل میشود قفل میکند.)

[p_ooya]

سلام
من کاری به منابع ندارم ولی شما وقتی یک ترد را create میکنید اعلام true به ترد میگوید که شروع به اجرا کند.
و resum هم به معنای اجرای مجدد هست.(من به این خاطر نظر دادم که شما گفتید فرم شما که بوسیله ترد اجرا و کنترل میشود قفل میکند.)

دقیقاً برعکس! این true مربوط به پارامتر Suspended سازنده هست. اما با این وجود من نظر شما رو امتحان کردم و بر خلاف نظر شما thread اصلاً اجرا نشد.

constructor Create(CreateSuspended: Boolean);

[vcldeveloper]

بخاطر این هست که دارید کدهای مورد نظر را از طریق Synchronize اجرا می کنید. قبلا درباره Synchronize و اینکه به چه شکلی عمل میکنه، صحبت کردم. بطور خلاصه، کدی که شما نوشتید، عملا در همون Thread اصلی اجرا میشه. برای توضیحات تکمیلی عبارت Synchronize را جستجو کنید.

[tdkhakpur]

سلام

 

myTH:=InitializeThread.Create(true);

myTH.FreeOnTerminate:=true;

myTH.Resume;

except

on e:Exception do ShowMessage(e.Message);

end;

شرمنده من تا حالا برنامه ای که کنار دستور create تابع resum استفاده شده باشد را ندیده بودم بالاخره این دودستور کنار هم من را به اشتباه انداخت به هر حال گر توانستید resume را به نحوی حذف کنید.
اگر منظورتان فرم خوش آمد باشد داخل کدهای فوق من جایی ندیدم که شما فرم را ببندید.

[p_ooya]

بخاطر این هست که دارید کدهای مورد نظر را از طریق Synchronize اجرا می کنید. قبلا درباره Synchronize و اینکه به چه شکلی عمل میکنه، صحبت کردم. بطور خلاصه، کدی که شما نوشتید، عملا در همون Thread اصلی اجرا میشه. برای توضیحات تکمیلی عبارت Synchronize را جستجو کنید.

سپاس.
من با توجه به آنچه شما گفتید ابتدا execute رو به صورت زیر تغییر دادم :

procedure InitializeThread.execute;

begin



    PostMessage(WelcomeForm.Handle,WM_THRD_MSG,0,0);

    Synchronize(settingvalues);



    PostMessage(WelcomeForm.Handle,WM_THRD_MSG,1,0);

    Synchronize(localdbconnect);



    PostMessage(WelcomeForm.Handle,WM_THRD_MSG,2,0);

    Synchronize(hostdbconnect);





    PostMessage(WelcomeForm.Handle,WM_THRD_MSG,3,0);

    Synchronize(settingqueries);



    Terminate;

    Exit;



end;

در واقع ارتباط با فرم رو از طریق پیام انجام دادم. ولی خب باز هم فرق نکرد. بعد کد رو به صورت زیر تغییر دادم :

procedure InitializeThread.execute;

begin

    PostMessage(WelcomeForm.Handle,WM_THRD_MSG,0,0);

    settingvalues;



    PostMessage(WelcomeForm.Handle,WM_THRD_MSG,1,0);

    localdbconnect;



    PostMessage(WelcomeForm.Handle,WM_THRD_MSG,2,0);

    hostdbconnect;



    PostMessage(WelcomeForm.Handle,WM_THRD_MSG,3,0);

    settingqueries;



    Terminate;

    Exit;



end;

یعنی فراخوانی توابع داخل خودِ کلاس Thread رو به صورت مستقیم انجام دادم و به نظر میاد که مشکل حل شده (آیا واقعاً حل شده؟).
حالا اگه مجموعه کارهایی که انجام داده ام درسته، پس چرا وقتی یه کلاس از نوع thread ایجاد می کنم خود ادیتور دلفی پیشنهاد میده که برای ارتباطش با فرم، از متد سنکرونایز استفاده کنم. از اون گذشته، وقتی شما گفتید که سایت رو دنبال عبارت سنکرونایز بگردم، (تقریباً) تمام نتایج حاصله حکایت از این داشت که باید از همین دستور سنکرون استفاده بشه. در حقیقت تنها جایی که میشد جواب رو پیدا کرد (البته اگر من پیدا کرده باشم) در این پست از این مقاله هست.
حالا بالاخره جوابی که من بهش رسیده ام درسته؟

[vcldeveloper]

من با توجه به آنچه شما گفتید ابتدا execute رو به صورت زیر تغییر دادم

کد اول اشتباه هست. چون هم دارید PostMessage می کنید، هم دارید Synchronize را فراخوانی می کنید. قبلا هم توضیح دادم که وقتی متد Synchronize را فراخوانی می کنید، در واقع Thread شما متوقف میشه، کد تابع مورد نظر شما در Thread اصلی برنامه (نه Threadایی که خودتون ساختید)، اجرا میشه، و بعد از اتمام تابع، ،Thread شما به کار خودش ادامه میده. پس اگر حجم بزرگی از کدهای شما توسط متد Synchronize اجرا بشه، عملا بخش بزرگی از کد شما در داخل همان Thread اصلی اجرا میشه، و شما منفعت خاصی از ایجاد Thread جدید بدست نمیارید.

Synchronize یک راه ساده برای تغییر رابط کاربر گرافیکی برنامه از سایر Thread ها (غیر از Thread اصلی) هست. اگر تغییراتی که در رابط کاربر اعمال می کنید (مثلا نمایش Progress bar) ساده هستند، استفاده از Synchronize مشکل خاصی بوجود نمیاره، ولی اگر کدهای تغییر رابط کاربر پیچیده باشند، استفاده از Synchronize مزیت استفاده از Thread را از بین میبره. در اون صورت باید از روش های دیگه ایی برای بروزرسانی رابط کاربر استفاده کنید، مثل ارسال Message به فرم مورد نظر، یا استفاده از هر یک از Synchronization Objectهای سیستم عامل، مثل Event, Critical Section, Mutex، و غیره.

در کد شما، از آنجایی که کدهایی که قرار دارید همگی مرتبط با بانک اطلاعاتی هستند، و ربط خاصی به رابط کاربر ندارند، نیازی به استفاده از متد Synchronize یا سایر روش های همزمان سازی نیست، و کد دوم پست قبلی شما باید بدون مشکل کار کنه.

در ضمن، در داخل متد Execute نیازی به فراخوانی Terminate نیست؛ هر وقت که اجرای Execute تمام شود، Thread مربوطه Terminate می شود. ثانیا، Exit برای خروج از یک تابع است. در پایان یک تابع، بطور خودکار از تابع خارج می شوید، پس نیازی به Exit در انتهای متد Execute هم نیست.

[Saeed_m_Farid]

سپاس.
در واقع ارتباط با فرم رو از طریق پیام انجام دادم. ولی خب باز هم فرق نکرد.
حالا بالاخره جوابی که من بهش رسیده ام درسته؟

کد اول اشتباه هست. چون هم دارید PostMessage می کنید، هم دارید Synchronize را فراخوانی می کنید.

در ادامه صحبت دوستان :

1. بنظر من تو کد دوم شما عملاً thread و PostMessage هاتون بی مصرف شدند، من احتمال میدم شما منظور آقای کشاورز از PostMessage رو درست متوجه نشدین؛ احتمالاً پیغامی که پست می کنید هیچ جایی هندل نمیشه (در حقیقت پیغام رو میفرستید هوا!) ، یعنی ویندوز پروسیجر موردنظر در یونیت WelcomeForm یا نوشته نشده یا پیغامتون رو درست پردازش نمی کنه.
   برای اینکه منظورم رو بهتر برسونم : شما تمام توابعی رو که تو thread نوشتید رو باید ببرید تو یونیت مربوط به WelcomeForm (یا جایی که WelcomeForm بهش دسترسی داره)، بعد یه Windows Procedure (یا Message Handler) بنویسید که توابع از طریق اون اجرا بشن، یعنی وقتی PostMessage می کنید به WelcomeForm، این توابع تو wndproc (همون Message Handler یا Windows Procedure) شما فراخوانی میشن، یه این صورت :

   
   
             (*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*)
   
   
   
   procedure TWelcomeForm.wndproc(var wndMsg: TMessage);
   
   begin
   
     try
   
       case wndMsg.Msg of
   
   
   
         WM_THRD_MSG:begin
   
           case wndMsg.WParam of
   
             0:settingvalues;
   
             1:localdbconnect;
   
             2:hostdbconnect;
   
             3:settingqueries;
   
             else // Addlog('Show ERROR!!!)
   
           end;
   
         end;
   
   
   
         //...
   
   
   
         else inherited;
   
       end;
   
     except on exp:Exception do
   
       // Addlog('Exception on wndproc['+IntToStr(wndMsg.Msg)+']: '+exp.Message);
   
     end;
   
   end;
   
   
   
             (*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*-*)
   
   
   
   

2. thread شما ورودی و خروجی اضافی نداره (یعنی سازنده و مخرب رو override نکردین)، و از طرف دیگه برای انجام عملیات منتظر رویدادی نیستید، پس نیازی نیست CreateSuspended رو ture بدین که مجبور باشید بعداً resume هم بکنیدش (با انتساب مقدار false بذارید thread مستقیم کارش رو انجام بده و تموم بشه)
3. نکته دیگه اینکه thread رو create کردین ولی از myTH هیچ استفاده ای نکردین؛ اگه کاری با myTH ندارید اصلاً نمیخواد instance رو انتساب بدین! یعنی میشه یه سطر :

   InitializeThread.Create(true);

   برای FreeOnTerminate هم میتونید اول InitializeThread.execute بنویسیدش ...

[AbiriAmir]

سلام
میدونم تاپیک مال قبله ولی WM_THRD_MSG چیه؟
خیلی لازم دازم
اگه میشه روی اون کد postmessage ها یکم توضیح بدین

[vcldeveloper]

WM_THRD_MSG چیه؟

یک نام برای یک message که برنامه نویس برای خودش ایجاد کرده، و هر زمان که اون Thread بخواد اطلاعاتی به Thread اصلی بفرسته، اون اطلاعات را از طریق این message ارسال میکنه.
در اون کد Thread اصلی بعد از دریافت پیام WM_THRD_MSG از Thread مورد نظر، داده های رسیده به همراه پیام (در اینجا پارامتر wparam) را پردازش میکنه، و متناسب با اینکه Thread چه مقداری را از این طریق ارسال کرده، کد خاصی را اجرا میکنه.

اگه میشه روی اون کد postmessage ها یکم توضیح بدین

درباره PostMessage چندین بار در همین تالار توضیح داده شده.

[AbiriAmir]

درباره PostMessage چندین بار در همین تالار توضیح داده شده.

من که تو کل سایت سرچ کردم چیزی راجع بهش نبود
فقط یکی دوتا مثال بود

اگه ممکنه مختصر توضیح بدین

پیشاپیش از لطفتون ممنونم . . .

[vcldeveloper]

من که تو کل سایت سرچ کردم چیزی راجع بهش نبود

کجا رو سرچ کردید؟!

http://www.barnamenevis.org/ta...ag=PostMessage

[AbiriAmir]

ولی تو هیچ کدومشون توضیح کامل و جامعی راجع به PostMessage نبود
یا تفاوت اون با SendMessage بود و یا...
به هر حال تو هیچ کدوم پارامتراش و نحوه کار کردن باهاش و پر کردن پارامتراش توضیح نداده بود
به هر حال...

------------------

یه نمونه رو جناب Mahmood_n گزاشتن
دانلود کردم
مشکلم تقریبا حل شد
به هر حال ممنون...

-------------------

راستی اگه با PostMessage کار کنیم دیگه مشکلی پیش نمیاد؟؟؟
منظورم اینه که دیگه مثل synchronize نیست که در ترید اصلی برنامه اجرا بشه؟؟؟