diff options
author | 2013-03-11 21:38:26 +0000 | |
---|---|---|
committer | 2013-03-11 21:38:26 +0000 | |
commit | dbca4a0ee5dac0b2f8d0ed4b1667adbf11363e35 (patch) | |
tree | d301a0b09a50e78076ab99184703a469a9be1c92 | |
parent | 5c19de4d070dfaebde92a5df4e54c959eef95cba (diff) | |
parent | 9447be65c34b66b01a19a85f4b07bb9c685e847a (diff) |
Merge "Add Thread::isRunning and Condition::signal(WakeUpType)" into jb-mr2-dev
-rw-r--r-- | include/utils/Condition.h | 13 | ||||
-rw-r--r-- | include/utils/Thread.h | 3 | ||||
-rw-r--r-- | libs/utils/Threads.cpp | 5 |
3 files changed, 21 insertions, 0 deletions
diff --git a/include/utils/Condition.h b/include/utils/Condition.h index 8852d53330..e63ba7e69c 100644 --- a/include/utils/Condition.h +++ b/include/utils/Condition.h @@ -48,6 +48,11 @@ public: SHARED = 1 }; + enum WakeUpType { + WAKE_UP_ONE = 0, + WAKE_UP_ALL = 1 + }; + Condition(); Condition(int type); ~Condition(); @@ -57,6 +62,14 @@ public: status_t waitRelative(Mutex& mutex, nsecs_t reltime); // Signal the condition variable, allowing one thread to continue. void signal(); + // Signal the condition variable, allowing one or all threads to continue. + void signal(WakeUpType type) { + if (type == WAKE_UP_ONE) { + signal(); + } else { + broadcast(); + } + } // Signal the condition variable, allowing all threads to continue. void broadcast(); diff --git a/include/utils/Thread.h b/include/utils/Thread.h index 4a34abd788..df30611352 100644 --- a/include/utils/Thread.h +++ b/include/utils/Thread.h @@ -67,6 +67,9 @@ public: // Do not call from this object's thread; will return WOULD_BLOCK in that case. status_t join(); + // Indicates whether this thread is running or not. + bool isRunning() const; + #ifdef HAVE_ANDROID_OS // Return the thread's kernel ID, same as the thread itself calling gettid() or // androidGetTid(), or -1 if the thread is not running. diff --git a/libs/utils/Threads.cpp b/libs/utils/Threads.cpp index eb964978e4..7b877e082f 100644 --- a/libs/utils/Threads.cpp +++ b/libs/utils/Threads.cpp @@ -875,6 +875,11 @@ status_t Thread::join() return mStatus; } +bool Thread::isRunning() const { + Mutex::Autolock _l(mLock); + return mRunning; +} + #ifdef HAVE_ANDROID_OS pid_t Thread::getTid() const { |