]> git.llucax.com Git - z.facultad/75.42/plaqui.git/blob - Server/src/runnable.cpp
Luca, si podes lleva esto, no creo que termine nada mas hoy
[z.facultad/75.42/plaqui.git] / Server / src / runnable.cpp
1 // vim: set noexpandtab tabstop=4 shiftwidth=4:
2 //----------------------------------------------------------------------------
3 //                                  PlaQui
4 //----------------------------------------------------------------------------
5 // This file is part of PlaQui.
6 //
7 // PlaQui is free software; you can redistribute it and/or modify it under the
8 // terms of the GNU General Public License as published by the Free Software
9 // Foundation; either version 2 of the License, or (at your option) any later
10 // version.
11 //
12 // PlaQui is distributed in the hope that it will be useful, but WITHOUT ANY
13 // WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
14 // FOR A PARTICULAR PURPOSE. See the GNU General Public License for more
15 // details.
16 //
17 // You should have received a copy of the GNU General Public License along
18 // with PlaQui; if not, write to the Free Software Foundation, Inc., 59 Temple
19 // Place, Suite 330, Boston, MA  02111-1307  USA
20 //----------------------------------------------------------------------------
21 // Creado:  dom oct 19 01:13:33 ART 2003
22 // Autores: Leandro Lucarella <llucare@fi.uba.ar>
23 //----------------------------------------------------------------------------
24 //
25 // $Id$
26 //
27
28 #include "plaqui/server/runnable.h"
29 #include <sigc++/class_slot.h>
30 #include <glibmm/thread.h>
31 #ifdef DEBUG
32 #       include <iostream>
33 #endif // DEBUG
34
35 using namespace std;
36
37 namespace PlaQui {
38
39 namespace Server {
40
41 Runnable::~Runnable(void) {
42 #ifdef DEBUG
43         cerr << __FILE__ << ": destructor(this = " << this << ")"
44                 << endl;
45 #endif // DEBUG
46 }
47
48 Runnable::Runnable(void): thread(0), stop(false) {
49 #ifdef DEBUG
50         cerr << __FILE__ << ": constructor." << endl;
51 #endif // DEBUG
52 }
53
54 void Runnable::static_run(Runnable* runner) {
55 #ifdef DEBUG
56         cerr << __FILE__ << ": static_run(runner = " << runner << ")"
57                 << endl;
58 #endif // DEBUG
59         runner->real_run();
60         runner->finished();
61         delete runner;
62 }
63
64 void Runnable::run(bool detach) {
65 #ifdef DEBUG
66         cerr << __FILE__ << ": run(detach = " << detach << ")" << endl;
67 #endif // DEBUG
68         // Si vamos a correr la tarea en un thread.
69         if (detach) {
70                 // Corremos el thread en una funcion estática para poder destruirlo al
71                 // finalizar, pasandole el puntero al objeto.
72                 thread = Glib::Thread::create(
73                                 SigC::bind<Runnable*>(SigC::slot(&Runnable::static_run), this),
74                                 true);
75         // Si no corremos la tarea normalmente.
76         } else {
77                 real_run();
78         }
79                 
80 }
81
82 void Runnable::finish(bool attach) {
83 #ifdef DEBUG
84         cerr << __FILE__ << ": finish(attach = " << attach << ")" << endl;
85 #endif // DEBUG
86         stop = true;
87         if (attach) {
88                 thread->join();
89         }
90 }
91
92 Runnable::SignalFinished& Runnable::signal_finished(void) {
93         return finished;
94 }
95
96 } // namespace Server
97
98 } // namespace PlaQui
99