File: ThreadCondition.h

package info (click to toggle)
kwave 0.7.2-5
  • links: PTS
  • area: main
  • in suites: sarge
  • size: 9,048 kB
  • ctags: 4,906
  • sloc: cpp: 31,275; ansic: 13,111; sh: 9,511; perl: 2,724; makefile: 786; asm: 145
file content (73 lines) | stat: -rw-r--r-- 2,356 bytes parent folder | download
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
/***************************************************************************
       ThreadCondition.h -  interface for POSIX type thread conditions
			     -------------------
    begin                : Sun Jun 03 2001
    copyright            : (C) 2001 by Thomas Eschenbacher
    email                : Thomas.Eschenbacher@gmx.de
 ***************************************************************************/

/***************************************************************************
 *                                                                         *
 *   This program 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 2 of the License, or     *
 *   (at your option) any later version.                                   *
 *                                                                         *
 ***************************************************************************/

#ifndef _THREAD_CONDITION_H_
#define _THREAD_CONDITION_H_

#include "config.h"
#include <pthread.h>

/**
 * @class ThreadCondition
 * Implements an interface for POSIX type thread conditions.
 *
 * @see the glibc info page
 *
 * @warning If it might happen that notify() might be called before wait(),
 *          the program will run into a deadlock. In this case you should
 *          consider using a Semaphore instead!
 *
 * @todo some error handling
 */
class ThreadCondition
{
public:
    /** Constructor */
    ThreadCondition();

    /** Destructor */
    virtual ~ThreadCondition();

    /**
     * Waits by setting the calling the calling thread into suspended
     * state until the condition has been set by some other thread.
     */
    void wait();

    /**
     * Sets the condition and wakes up at <b>only one</b> of the threads
     * that are waiting for the condition and suspended.
     */
    void notify();

    /**
     * Sets the condition and wakes up <b>all</em> threads that are currently
     * waiting for the condition and are suspended.
     */
    void notifyAll();

private:

    /** the internal thread condition */
    pthread_cond_t m_condition;

    /** lock used for setting the thread condition to a different value */
    pthread_mutex_t m_lock;

};

#endif /* _THREAD_CONDITION_H_ */