Mercurial > octave-libgccjit
view libgui/src/thread-manager.h @ 17922:b5bf26a054bd
interrupt interpreter thread in GUI instead of calling "raise (SIGINT)"
* thread-manager.h, thread-manager.cc: New files.
* libgui/src/module.mk: Update file lists.
* octave-gui.cc (octave_start_gui): Block SIGINT at startup.
* octave-interpreter.h, octave-interpreter.cc
(octave_interpreter::thread_manager): New data member.
(octave_interpreter::execute): Register current thread and unblock
interrupt signal.
(octave_interpreter::interrupt): Call thread_manager::interrupt
instead of calling ::raising (SIGINT).
author | John W. Eaton <jwe@octave.org> |
---|---|
date | Tue, 12 Nov 2013 19:24:49 -0500 |
parents | |
children |
line wrap: on
line source
/* Copyright (C) 2013 John W. Eaton This file is part of Octave. Octave is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 3 of the License, or (at your option) any later version. Octave is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with Octave; see the file COPYING. If not, see <http://www.gnu.org/licenses/>. */ #if !defined (octave_thread_manager_h) #define octave_thread_manager_h 1 class octave_base_thread_manager { public: friend class octave_thread_manager; octave_base_thread_manager (void) : count (1) { } octave_base_thread_manager (const octave_base_thread_manager&) : count (1) { } virtual ~octave_base_thread_manager (void) { } virtual void register_current_thread (void) = 0; virtual void interrupt (void) = 0; protected: int count; }; class octave_thread_manager { public: octave_thread_manager (void); ~octave_thread_manager (void) { if (--rep->count == 0) delete rep; } octave_thread_manager (const octave_thread_manager& tm) : rep (tm.rep) { } octave_thread_manager& operator = (const octave_thread_manager& tm) { if (rep != tm.rep) { if (--rep->count == 0) delete rep; rep = tm.rep; rep->count++; } return *this; } void register_current_thread (void) { rep->register_current_thread (); } void interrupt (void) { rep->interrupt (); } static void block_interrupt_signal (void); static void unblock_interrupt_signal (void); private: octave_base_thread_manager *rep; static octave_base_thread_manager *create_rep (void); }; #endif