]> granicus.if.org Git - imagemagick/blob - magick/thread-private.h
(no commit message)
[imagemagick] / magick / thread-private.h
1 /*
2   Copyright 1999-2011 ImageMagick Studio LLC, a non-profit organization
3   dedicated to making software imaging solutions freely available.
4
5   You may not use this file except in compliance with the License.
6   obtain a copy of the License at
7
8     http://www.imagemagick.org/script/license.php
9
10   Unless required by applicable law or agreed to in writing, software
11   distributed under the License is distributed on an "AS IS" BASIS,
12   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13   See the License for the specific language governing permissions and
14   limitations under the License.
15
16   MagickCore private methods for internal threading.
17 */
18 #ifndef _MAGICKCORE_THREAD_PRIVATE_H
19 #define _MAGICKCORE_THREAD_PRIVATE_H
20
21 #if defined(__cplusplus) || defined(c_plusplus)
22 extern "C" {
23 #endif
24
25 #include <magick/thread_.h>
26
27 #define omp_throttle(factor)  num_threads(omp_get_max_threads() >> (factor))
28
29 #if (__GNUC__ > 3) || ((__GNUC__ == 3) && (__GNUC_MINOR > 10))
30 #define MagickCachePrefetch(address,mode,locality) \
31   __builtin_prefetch(address,mode,locality)
32 #else
33 #define MagickCachePrefetch(address,mode,locality)
34 #endif
35
36 #if defined(MAGICKCORE_THREAD_SUPPORT)
37   typedef pthread_mutex_t MagickMutexType;
38 #elif defined(MAGICKCORE_WINDOWS_SUPPORT)
39   typedef CRITICAL_SECTION MagickMutexType;
40 #else
41   typedef size_t MagickMutexType;
42 #endif
43
44 static inline MagickThreadType GetMagickThreadId(void)
45 {
46 #if defined(MAGICKCORE_THREAD_SUPPORT)
47   return(pthread_self());
48 #elif defined(MAGICKCORE_WINDOWS_SUPPORT)
49   return(GetCurrentThreadId());
50 #else
51   return(getpid());
52 #endif
53 }
54
55 static inline size_t GetMagickThreadSignature(void)
56 {
57 #if defined(MAGICKCORE_THREAD_SUPPORT)
58   {
59     union
60     {
61       pthread_t
62         id;
63
64       size_t
65         signature;
66     } magick_thread;
67
68     magick_thread.signature=0UL;
69     magick_thread.id=pthread_self();
70     return(magick_thread.signature);
71   }
72 #elif defined(MAGICKCORE_WINDOWS_SUPPORT)
73   return((size_t) GetCurrentThreadId());
74 #else
75   return((size_t) getpid());
76 #endif
77 }
78
79 static inline MagickBooleanType IsMagickThreadEqual(const MagickThreadType id)
80 {
81 #if defined(MAGICKCORE_THREAD_SUPPORT)
82   if (pthread_equal(id,pthread_self()) != 0)
83     return(MagickTrue);
84 #elif defined(MAGICKCORE_WINDOWS_SUPPORT)
85   if (id == GetCurrentThreadId())
86     return(MagickTrue);
87 #else
88   if (id == getpid())
89     return(MagickTrue);
90 #endif
91   return(MagickFalse);
92 }
93
94 /*
95   Lightweight OpenMP methods.
96 */
97 static inline size_t GetOpenMPMaximumThreads(void)
98 {
99 #if defined(MAGICKCORE_OPENMP_SUPPORT) && (_OPENMP >= 200203)
100   {
101     ssize_t
102       threads;
103
104     static size_t
105       maximum_threads = 1UL;
106
107     threads=omp_get_max_threads();
108     if (threads > (ssize_t) maximum_threads)
109       maximum_threads=threads;
110     return(maximum_threads);
111   }
112 #else
113   return(1UL);
114 #endif
115 }
116
117 static inline int GetOpenMPThreadId(void)
118 {
119 #if defined(MAGICKCORE_OPENMP_SUPPORT) && (_OPENMP >= 200203)
120   return(omp_get_thread_num());
121 #else
122   return(0);
123 #endif
124 }
125
126 static inline void SetOpenMPMaximumThreads(const int threads)
127 {
128 #if defined(MAGICKCORE_OPENMP_SUPPORT) && (_OPENMP >= 200203)
129   omp_set_num_threads(threads);
130 #else
131   (void) threads;
132 #endif
133 }
134
135 static inline void SetOpenMPNested(const int value)
136 {
137 #if defined(MAGICKCORE_OPENMP_SUPPORT) && (_OPENMP >= 200203)
138   omp_set_nested(value);
139 #else
140   (void) value;
141 #endif
142 }
143
144 #if defined(__cplusplus) || defined(c_plusplus)
145 }
146 #endif
147
148 #endif