Changeset 162 for MicroThreading/Demo


Ignore:
Timestamp:
Feb 7, 2011, 1:04:27 PM (14 years ago)
Author:
george
Message:
  • Add: MicroThread critical section.
  • Add: Thread list to microthread list window.
Location:
MicroThreading/Demo
Files:
3 edited

Legend:

Unmodified
Added
Removed

  • MicroThreading/Demo/Demo.lpi

    r161 r162  
    3131      </local>
    3232    </RunParams>
    33     <RequiredPackages Count="2">
     33    <RequiredPackages Count="3">
    3434      <Item1>
    35         <PackageName Value="Microthreading"/>
     35        <PackageName Value="LCLBase"/>
     36        <MinVersion Major="1" Release="1" Valid="True"/>
    3637      </Item1>
    3738      <Item2>
     39        <PackageName Value="Microthreading"/>
     40      </Item2>
     41      <Item3>
    3842        <PackageName Value="LCL"/>
    39       </Item2>
     43      </Item3>
    4044    </RequiredPackages>
    41     <Units Count="24">
     45    <Units Count="28">
    4246      <Unit0>
    4347        <Filename Value="Demo.lpr"/>
    … …  
    5559        <ResourceBaseClass Value="Form"/>
    5660        <UnitName Value="UMainForm"/>
    57         <EditorIndex Value="1"/>
    58         <WindowIndex Value="0"/>
    59         <TopLine Value="369"/>
    60         <CursorPos X="1" Y="379"/>
     61        <EditorIndex Value="6"/>
     62        <WindowIndex Value="0"/>
     63        <TopLine Value="372"/>
     64        <CursorPos X="21" Y="378"/>
    6165        <UsageCount Value="270"/>
    6266        <Loaded Value="True"/>
     67        <LoadedDesigner Value="True"/>
    6368      </Unit1>
    6469      <Unit2>
    … …  
    6873        <EditorIndex Value="0"/>
    6974        <WindowIndex Value="0"/>
    70         <TopLine Value="500"/>
    71         <CursorPos X="1" Y="517"/>
     75        <TopLine Value="976"/>
     76        <CursorPos X="18" Y="986"/>
    7277        <UsageCount Value="136"/>
    7378        <Loaded Value="True"/>
    … …  
    131136        <ResourceBaseClass Value="Form"/>
    132137        <UnitName Value="UMicroThreadList"/>
    133         <WindowIndex Value="0"/>
    134         <TopLine Value="1"/>
    135         <CursorPos X="44" Y="17"/>
    136         <UsageCount Value="21"/>
     138        <EditorIndex Value="4"/>
     139        <WindowIndex Value="0"/>
     140        <TopLine Value="83"/>
     141        <CursorPos X="84" Y="94"/>
     142        <UsageCount Value="23"/>
     143        <Loaded Value="True"/>
     144        <LoadedDesigner Value="True"/>
    137145      </Unit10>
    138146      <Unit11>
    … …  
    228236        <UsageCount Value="16"/>
    229237      </Unit23>
     238      <Unit24>
     239        <Filename Value="../../../../Projekty2/FreePascalManager/trunk/Instance/1/FPC/packages/fcl-base/src/syncobjs.pp"/>
     240        <UnitName Value="syncobjs"/>
     241        <EditorIndex Value="5"/>
     242        <WindowIndex Value="0"/>
     243        <TopLine Value="35"/>
     244        <CursorPos X="18" Y="45"/>
     245        <UsageCount Value="12"/>
     246        <Loaded Value="True"/>
     247      </Unit24>
     248      <Unit25>
     249        <Filename Value="../../../../Projekty2/FreePascalManager/trunk/Instance/1/Lazarus/lcl/include/customlistview.inc"/>
     250        <EditorIndex Value="1"/>
     251        <WindowIndex Value="0"/>
     252        <TopLine Value="548"/>
     253        <CursorPos X="1" Y="561"/>
     254        <UsageCount Value="11"/>
     255        <Loaded Value="True"/>
     256      </Unit25>
     257      <Unit26>
     258        <Filename Value="../../../../Projekty2/FreePascalManager/trunk/Instance/1/Lazarus/lcl/include/listitem.inc"/>
     259        <EditorIndex Value="2"/>
     260        <WindowIndex Value="0"/>
     261        <TopLine Value="798"/>
     262        <CursorPos X="1" Y="821"/>
     263        <UsageCount Value="11"/>
     264        <Loaded Value="True"/>
     265      </Unit26>
     266      <Unit27>
     267        <Filename Value="../../../../Projekty2/FreePascalManager/trunk/Instance/1/Lazarus/lcl/include/listitems.inc"/>
     268        <EditorIndex Value="3"/>
     269        <WindowIndex Value="0"/>
     270        <TopLine Value="65"/>
     271        <CursorPos X="29" Y="75"/>
     272        <UsageCount Value="11"/>
     273        <Loaded Value="True"/>
     274      </Unit27>
    230275    </Units>
    231276    <JumpHistory Count="30" HistoryIndex="29">
    232277      <Position1>
    233278        <Filename Value="../UMicroThreading.pas"/>
    234         <Caret Line="462" Column="1" TopLine="451"/>
     279        <Caret Line="371" Column="16" TopLine="350"/>
    235280      </Position1>
    236281      <Position2>
    237282        <Filename Value="../UMicroThreading.pas"/>
    238         <Caret Line="463" Column="1" TopLine="451"/>
     283        <Caret Line="652" Column="38" TopLine="631"/>
    239284      </Position2>
    240285      <Position3>
    241286        <Filename Value="../UMicroThreading.pas"/>
    242         <Caret Line="434" Column="1" TopLine="423"/>
     287        <Caret Line="746" Column="12" TopLine="725"/>
    243288      </Position3>
    244289      <Position4>
    245290        <Filename Value="../UMicroThreading.pas"/>
    246         <Caret Line="462" Column="1" TopLine="451"/>
     291        <Caret Line="750" Column="31" TopLine="729"/>
    247292      </Position4>
    248293      <Position5>
    249294        <Filename Value="../UMicroThreading.pas"/>
    250         <Caret Line="463" Column="1" TopLine="451"/>
     295        <Caret Line="753" Column="26" TopLine="732"/>
    251296      </Position5>
    252297      <Position6>
    253298        <Filename Value="../UMicroThreading.pas"/>
    254         <Caret Line="545" Column="1" TopLine="534"/>
     299        <Caret Line="935" Column="13" TopLine="914"/>
    255300      </Position6>
    256301      <Position7>
    257302        <Filename Value="../UMicroThreading.pas"/>
    258         <Caret Line="429" Column="1" TopLine="418"/>
     303        <Caret Line="983" Column="31" TopLine="968"/>
    259304      </Position7>
    260305      <Position8>
    261306        <Filename Value="../UMicroThreading.pas"/>
    262         <Caret Line="430" Column="1" TopLine="418"/>
     307        <Caret Line="1013" Column="24" TopLine="992"/>
    263308      </Position8>
    264309      <Position9>
    265310        <Filename Value="../UMicroThreading.pas"/>
    266         <Caret Line="574" Column="1" TopLine="563"/>
     311        <Caret Line="8" Column="19" TopLine="1"/>
    267312      </Position9>
    268313      <Position10>
    269314        <Filename Value="../UMicroThreading.pas"/>
    270         <Caret Line="575" Column="1" TopLine="563"/>
     315        <Caret Line="652" Column="51" TopLine="639"/>
    271316      </Position10>
    272317      <Position11>
    273318        <Filename Value="../UMicroThreading.pas"/>
    274         <Caret Line="576" Column="1" TopLine="563"/>
     319        <Caret Line="645" Column="28" TopLine="639"/>
    275320      </Position11>
    276321      <Position12>
    277322        <Filename Value="../UMicroThreading.pas"/>
    278         <Caret Line="572" Column="1" TopLine="563"/>
     323        <Caret Line="653" Column="43" TopLine="639"/>
    279324      </Position12>
    280325      <Position13>
    281326        <Filename Value="../UMicroThreading.pas"/>
    282         <Caret Line="573" Column="1" TopLine="563"/>
     327        <Caret Line="479" Column="1" TopLine="466"/>
    283328      </Position13>
    284329      <Position14>
    285330        <Filename Value="../UMicroThreading.pas"/>
    286         <Caret Line="434" Column="1" TopLine="423"/>
     331        <Caret Line="712" Column="1" TopLine="699"/>
    287332      </Position14>
    288333      <Position15>
    289334        <Filename Value="../UMicroThreading.pas"/>
    290         <Caret Line="462" Column="1" TopLine="451"/>
     335        <Caret Line="582" Column="18" TopLine="571"/>
    291336      </Position15>
    292337      <Position16>
    293338        <Filename Value="../UMicroThreading.pas"/>
    294         <Caret Line="463" Column="1" TopLine="451"/>
     339        <Caret Line="583" Column="65" TopLine="571"/>
    295340      </Position16>
    296341      <Position17>
    297342        <Filename Value="../UMicroThreading.pas"/>
    298         <Caret Line="545" Column="30" TopLine="534"/>
     343        <Caret Line="582" Column="20" TopLine="571"/>
    299344      </Position17>
    300345      <Position18>
    301346        <Filename Value="../UMicroThreading.pas"/>
    302         <Caret Line="429" Column="1" TopLine="418"/>
     347        <Caret Line="583" Column="1" TopLine="571"/>
    303348      </Position18>
    304349      <Position19>
    305350        <Filename Value="../UMicroThreading.pas"/>
    306         <Caret Line="430" Column="1" TopLine="418"/>
     351        <Caret Line="711" Column="1" TopLine="698"/>
    307352      </Position19>
    308353      <Position20>
    309354        <Filename Value="../UMicroThreading.pas"/>
    310         <Caret Line="574" Column="1" TopLine="563"/>
     355        <Caret Line="712" Column="1" TopLine="698"/>
    311356      </Position20>
    312357      <Position21>
    313358        <Filename Value="../UMicroThreading.pas"/>
    314         <Caret Line="575" Column="1" TopLine="563"/>
     359        <Caret Line="713" Column="1" TopLine="698"/>
    315360      </Position21>
    316361      <Position22>
    317362        <Filename Value="../UMicroThreading.pas"/>
    318         <Caret Line="513" Column="34" TopLine="504"/>
     363        <Caret Line="714" Column="1" TopLine="698"/>
    319364      </Position22>
    320365      <Position23>
    321366        <Filename Value="../UMicroThreading.pas"/>
    322         <Caret Line="517" Column="1" TopLine="504"/>
     367        <Caret Line="715" Column="1" TopLine="698"/>
    323368      </Position23>
    324369      <Position24>
    325         <Filename Value="../UMicroThreading.pas"/>
    326         <Caret Line="545" Column="1" TopLine="534"/>
     370        <Filename Value="../UMicroThreadList.pas"/>
     371        <Caret Line="95" Column="54" TopLine="83"/>
    327372      </Position24>
    328373      <Position25>
    329         <Filename Value="UMainForm.pas"/>
    330         <Caret Line="379" Column="1" TopLine="369"/>
     374        <Filename Value="../UMicroThreading.pas"/>
     375        <Caret Line="240" Column="45" TopLine="227"/>
    331376      </Position25>
    332377      <Position26>
    333378        <Filename Value="../UMicroThreading.pas"/>
    334         <Caret Line="613" Column="1" TopLine="602"/>
     379        <Caret Line="984" Column="40" TopLine="979"/>
    335380      </Position26>
    336381      <Position27>
    337382        <Filename Value="../UMicroThreading.pas"/>
    338         <Caret Line="428" Column="6" TopLine="417"/>
     383        <Caret Line="992" Column="38" TopLine="979"/>
    339384      </Position27>
    340385      <Position28>
    341386        <Filename Value="../UMicroThreading.pas"/>
    342         <Caret Line="434" Column="3" TopLine="504"/>
     387        <Caret Line="989" Column="55" TopLine="976"/>
    343388      </Position28>
    344389      <Position29>
    345390        <Filename Value="../UMicroThreading.pas"/>
    346         <Caret Line="579" Column="1" TopLine="568"/>
     391        <Caret Line="990" Column="24" TopLine="976"/>
    347392      </Position29>
    348393      <Position30>
    349394        <Filename Value="../UMicroThreading.pas"/>
    350         <Caret Line="435" Column="1" TopLine="424"/>
     395        <Caret Line="989" Column="29" TopLine="976"/>
    351396      </Position30>
    352397    </JumpHistory>
    … …  
    389434  </CompilerOptions>
    390435  <Debugging>
    391     <BreakPoints Count="2">
     436    <BreakPoints Count="3">
    392437      <Item1>
    393438        <Source Value="../UMicroThreading.pas"/>
    394         <Line Value="261"/>
     439        <Line Value="280"/>
    395440      </Item1>
    396441      <Item2>
    … …  
    398443        <Line Value="1036"/>
    399444      </Item2>
     445      <Item3>
     446        <Source Value="../UMicroThreading.pas"/>
     447        <Line Value="321"/>
     448      </Item3>
    400449    </BreakPoints>
    401450    <Watches Count="2">

  • MicroThreading/Demo/UMainForm.lfm

    r160 r162  
    1616    Top = 8
    1717    Width = 802
    18     ActivePage = TabSheet1
     18    ActivePage = TabSheet2
    1919    Anchors = [akTop, akLeft, akRight, akBottom]
    20     TabIndex = 1
     20    TabIndex = 0
    2121    TabOrder = 0
    2222    object TabSheet2: TTabSheet
    … …  
    2626      object GroupBox1: TGroupBox
    2727        Left = 6
    28         Height = 81
     28        Height = 123
    2929        Top = 143
    3030        Width = 205
    3131        Caption = 'State'
    32         ClientHeight = 63
     32        ClientHeight = 105
    3333        ClientWidth = 201
    3434        TabOrder = 0
    … …  
    142142        end
    143143      end
    144       object ListView2: TListView
    145         Left = 6
    146         Height = 237
    147         Top = 247
    148         Width = 206
    149         Anchors = [akTop, akLeft, akBottom]
    150         Columns = <       
    151           item
    152             Caption = 'Id'
    153           end       
    154           item
    155             Caption = 'State'
    156             Width = 135
    157           end>
    158         OwnerData = True
    159         TabOrder = 2
    160         ViewStyle = vsReport
    161         OnData = ListView2Data
    162       end
    163       object Label13: TLabel
    164         Left = 7
    165         Height = 14
    166         Top = 233
    167         Width = 44
    168         Caption = 'Threads:'
    169         ParentColor = False
    170       end
    171144      object Button4: TButton
    172145        Left = 226
    … …  
    176149        Caption = 'Show manager'
    177150        OnClick = Button4Click
    178         TabOrder = 3
     151        TabOrder = 2
    179152      end
    180153    end
    … …  
    195168        Left = 10
    196169        Height = 25
    197         Top = 223
     170        Top = 266
    198171        Width = 104
    199172        Caption = 'Clear jobs'
    … …  
    230203      end
    231204      object Button1: TButton
    232         Left = 230
    233         Height = 25
    234         Top = 239
     205        Left = 316
     206        Height = 25
     207        Top = 266
    235208        Width = 75
    236209        Caption = 'Clear memo'
    … …  
    258231      object GroupBox3: TGroupBox
    259232        Left = 10
    260         Height = 137
     233        Height = 185
    261234        Top = 74
    262235        Width = 292
    263236        Caption = 'Do inside jobs'
    264         ClientHeight = 119
     237        ClientHeight = 167
    265238        ClientWidth = 288
    266239        TabOrder = 6
    … …  
    280253          Width = 90
    281254          MaxValue = 100000
     255          OnChange = CheckBox1Change
    282256          TabOrder = 1
    283257          Value = 100
    … …  
    345319          TabOrder = 6
    346320        end
     321        object CheckBox4: TCheckBox
     322          Left = 6
     323          Height = 17
     324          Top = 110
     325          Width = 123
     326          Caption = 'Wait in critical section'
     327          OnChange = CheckBox4Change
     328          TabOrder = 7
     329        end
     330        object SpinEdit6: TSpinEdit
     331          Left = 186
     332          Height = 21
     333          Top = 104
     334          Width = 70
     335          MaxValue = 100000
     336          OnChange = CheckBox4Change
     337          TabOrder = 8
     338          Value = 100
     339        end
     340        object Label18: TLabel
     341          Left = 264
     342          Height = 14
     343          Top = 110
     344          Width = 14
     345          Caption = 'ms'
     346          ParentColor = False
     347        end
    347348      end
    348349    end

  • MicroThreading/Demo/UMainForm.pas

    r161 r162  
    2020    MainForm: TMainForm;
    2121    procedure DoWriteToMemo;
     22    constructor Create(CreateSuspended: Boolean;
     23      const StackSize: SizeUInt = DefaultStackSize);
     24    destructor Destroy; override;
    2225  end;
    2326
    … …  
    3841    CheckBox2: TCheckBox;
    3942    CheckBox3: TCheckBox;
     43    CheckBox4: TCheckBox;
    4044    CheckBoxUseMainThread: TCheckBox;
    4145    GroupBox1: TGroupBox;
    … …  
    4549    Label11: TLabel;
    4650    Label12: TLabel;
    47     Label13: TLabel;
    4851    Label14: TLabel;
    4952    Label15: TLabel;
    5053    Label16: TLabel;
    5154    Label17: TLabel;
     55    Label18: TLabel;
    5256    Label2: TLabel;
    5357    Label3: TLabel;
    … …  
    5862    Label8: TLabel;
    5963    Label9: TLabel;
    60     ListView2: TListView;
    6164    Memo1: TMemo;
    6265    PageControl1: TPageControl;
    … …  
    6669    SpinEdit4: TSpinEdit;
    6770    SpinEdit5: TSpinEdit;
     71    SpinEdit6: TSpinEdit;
    6872    TabSheet1: TTabSheet;
    6973    TabSheet2: TTabSheet;
    … …  
    8387    procedure CheckBox2Change(Sender: TObject);
    8488    procedure CheckBox3Change(Sender: TObject);
     89    procedure CheckBox4Change(Sender: TObject);
    8590    procedure CheckBoxUseMainThreadChange(Sender: TObject);
    8691    procedure FormCreate(Sender: TObject);
    … …  
    9196    procedure SpinEdit3Change(Sender: TObject);
    9297    procedure SpinEdit5Change(Sender: TObject);
     98    procedure SpinEdit6Change(Sender: TObject);
    9399    procedure TimerRedrawTimer(Sender: TObject);
    94100  private
    95101    MicroThreadList: TMicroThreadList;
     102    Lock: TMicroThreadCriticalSection;
    96103    LastException: Exception;
    97104    LastExceptionSender: TObject;
    … …  
    102109    DoWriteToMemo: Boolean;
    103110    DoSleep: Boolean;
     111    DoCriticalSection: Boolean;
    104112    RaiseException: Boolean;
    105113    SleepDuration: Integer;
     114    CriticalSectionSleepDuration: Integer;
    106115    DoWaitForEvent: Boolean;
    107116    Event: TMicroThreadEvent;
    … …  
    129138  MicroThreadList := TMicroThreadList.Create(Self);
    130139  UMicroThreading.ExceptionHandler := ShowException;
     140  Lock := TMicroThreadCriticalSection.Create;
    131141end;
    132142
    … …  
    280290end;
    281291
     292procedure TMainForm.CheckBox4Change(Sender: TObject);
     293begin
     294  CriticalSectionSleepDuration := SpinEdit4.Value;
     295  DoCriticalSection := CheckBox4.Checked;
     296end;
     297
    282298procedure TMainForm.CheckBoxUseMainThreadChange(Sender: TObject);
    283299begin
    … …  
    290306  MainScheduler.Active := False;
    291307  Event.Free;
     308  Lock.Free;
    292309end;
    293310
    … …  
    303320procedure TMainForm.ListView2Data(Sender: TObject; Item: TListItem);
    304321begin
    305   if Item.Index < MainScheduler.ThreadPoolCount then
    306   try
    307     MainScheduler.ThreadPoolLock.Acquire;
    308     with TMicroThreadThread(MainScheduler.ThreadPool[Item.Index]) do begin
    309       Item.Caption := IntToStr(ThreadID);
    310       Item.SubItems.Add(MicroThreadThreadStateText[State]);
    311     end;
    312   finally
    313     MainScheduler.ThreadPoolLock.Release;
    314   end;
    315322end;
    316323
    … …  
    330337end;
    331338
     339procedure TMainForm.SpinEdit6Change(Sender: TObject);
     340begin
     341end;
     342
    332343procedure TMainForm.TimerRedrawTimer(Sender: TObject);
    333344begin
    334   if ListView2.Items.Count <> MainScheduler.ThreadPoolCount then
    335     ListView2.Items.Count := MainScheduler.ThreadPoolCount;
    336   ListView2.Items[-1];
    337   ListView2.Refresh;
    338 
    339345  Label2.Caption := DateTimeToStr(NowPrecise) + ' ' +
    340346    FloatToStr(Frac(NowPrecise / OneSecond));
    … …  
    369375begin
    370376  for I := 0 to MainForm.Iterations - 1 do begin
    371     try
    372377    Q := 0;
    373     while Q < 100 do Inc(Q);
     378    while Q < 100000 do Inc(Q);
    374379    if MainForm.DoWriteToMemo then Synchronize(DoWriteToMemo);
    375380    if MainForm.DoWaitForEvent then MainForm.Event.WaitFor(MainForm.WaitForEventDuration * OneMillisecond);
    … …  
    379384      raise Exception.Create('Exception from microthread');
    380385    end;
     386    if MainForm.DoCriticalSection then begin
     387      try
     388        MainForm.Lock.Acquire;
     389        MTSleep(MainForm.CriticalSectionSleepDuration * OneMillisecond);
     390      finally
     391        MainForm.Lock.Release;
     392      end;
     393    end;
    381394    //WorkerSubRoutine;
    382395    Completion := I / MainForm.Iterations;
    383396    Yield;
    384 
    385     except
    386       Q := 0;
    387       raise  Exception.Create('Exception from microthread');
    388     end;
    389397  end;
    390398end;
    … …  
    395403end;
    396404
     405constructor TWorker.Create(CreateSuspended: Boolean; const StackSize: SizeUInt);
     406begin
     407  inherited;
     408end;
     409
     410destructor TWorker.Destroy;
     411begin
     412  inherited Destroy;
     413end;
     414
    397415end.
    398416
Note: See TracChangeset for help on using the changeset viewer.