https://github.com/root-project/root
Tip revision: db2870b025dfc8a401f509206982871862975e29 authored by Unknown Author on 04 August 2006, 10:22:45 UTC
This commit was manufactured by cvs2svn to create tag 'v5-12-00b'.
This commit was manufactured by cvs2svn to create tag 'v5-12-00b'.
Tip revision: db2870b
threadsh1.C
// Example of a simple script creating 3 threads.
// This script can only be executed via ACliC .x threadsh1.C++.
// Before executing the script, load the Thread library with:
// gSystem->Load("libThread");
// This is not needed anymore due to the rootmap facility which
// automatically loads the needed libraries.
#include "TCanvas.h"
#include "TFrame.h"
#include "TPad.h"
#include "TH1F.h"
#include "TRandom.h"
#include "TThread.h"
#include <Riostream.h>
TCanvas *c[4];
TH1F *hpx[4];
TThread *t[5];
Bool_t finished;
void *handle(void *ptr)
{
long nr = (long) ptr;
int nfills = 2500000;
int upd = 5000;
char name[32];
sprintf(name,"hpx%ld",nr);
TThread::Lock();
hpx[nr] = new TH1F(name,"This is the px distribution",100,-4,4);
hpx[nr]->SetFillColor(48);
TThread::UnLock();
Float_t px, py, pz;
gRandom->SetSeed();
for (Int_t i = 0; i < nfills; i++) {
gRandom->Rannor(px,py);
pz = px*px + py*py;
hpx[nr]->Fill(px);
if (i && (i%upd) == 0) {
if (i == upd) {
TThread::Lock();
c[nr]->cd();
hpx[nr]->Draw();
TThread::UnLock();
}
c[nr]->Modified();
gSystem->Sleep(10);
}
}
return 0;
}
void *joiner(void *)
{
t[0]->Join();
t[1]->Join();
t[2]->Join();
t[3]->Join();
finished = kTRUE;
return 0;
}
void threadsh1()
{
#ifdef __CINT__
printf("This script can only be executed via ACliC: .x threadsh1.C++\n");
return;
#endif
finished = kFALSE;
gDebug = 1;
c[0] = new TCanvas("c0","Dynamic Filling Example",100,20,400,300);
c[0]->SetFillColor(42);
c[0]->GetFrame()->SetFillColor(21);
c[0]->GetFrame()->SetBorderSize(6);
c[0]->GetFrame()->SetBorderMode(-1);
c[1] = new TCanvas("c1","Dynamic Filling Example",510,20,400,300);
c[1]->SetFillColor(42);
c[1]->GetFrame()->SetFillColor(21);
c[1]->GetFrame()->SetBorderSize(6);
c[1]->GetFrame()->SetBorderMode(-1);
c[2] = new TCanvas("c2","Dynamic Filling Example",100,350,400,300);
c[2]->SetFillColor(42);
c[2]->GetFrame()->SetFillColor(21);
c[2]->GetFrame()->SetBorderSize(6);
c[2]->GetFrame()->SetBorderMode(-1);
c[3] = new TCanvas("c3","Dynamic Filling Example",510,350,400,300);
c[3]->SetFillColor(42);
c[3]->GetFrame()->SetFillColor(21);
c[3]->GetFrame()->SetBorderSize(6);
c[3]->GetFrame()->SetBorderMode(-1);
printf("Starting Thread 0\n");
t[0] = new TThread("t0", handle, (void*) 0);
t[0]->Run();
printf("Starting Thread 1\n");
t[1] = new TThread("t1", handle, (void*) 1);
t[1]->Run();
printf("Starting Thread 2\n");
t[2] = new TThread("t2", handle, (void*) 2);
t[2]->Run();
printf("Starting Thread 3\n");
t[3] = new TThread("t3", handle, (void*) 3);
t[3]->Run();
printf("Starting Thread 4\n");
t[4] = new TThread("t4", joiner, (void*) 3);
t[4]->Run();
TThread::Ps();
while (!finished) {
for (int i = 0; i < 4; i++) {
if (c[i]->IsModified()) {
printf("Update canvas %d\n", i);
c[i]->Update();
}
}
gSystem->ProcessEvents();
}
t[4]->Join();
TThread::Ps();
delete t[0];
delete t[1];
delete t[2];
delete t[3];
delete t[4];
}