Source/Base/FieldContainer/Node/testNodeThread.cpp

   1
   2 #include "OSGBaseInitFunctions.h"
   3 #include "OSGNode.h"
   4
   5 #ifdef OSG_USE_PTHREADS
   6 #include <pthread.h>
   7
   8 pthread_t oThread;
   9
  10 void *runThread(void *)
  11 {
  12     fprintf(stderr, "run thread \n");
  13
  14     fprintf(stderr, "th : %p %p %d 0x%016" PRIx64 " 0x%016" PRIx64 "\n",
  15             static_cast<void *>(OSG::Thread::getCurrentChangeList   ()),
  16             static_cast<void *>(OSG::Thread::getCurrent             ()),
  17                                 OSG::Thread::getCurrentAspect       (),
  18                                 OSG::Thread::getCurrentNamespaceMask(),
  19                                 OSG::Thread::getCurrentLocalFlags   ());
  20
  21     fprintf(stderr, "th : %p %p %d 0x%016" PRIx64 " 0x%016" PRIx64 "\n",
  22             static_cast<void *>(OSG::Thread::getCurrentChangeList   ()),
  23             static_cast<void *>(OSG::Thread::getCurrent             ()),
  24                                 OSG::Thread::getCurrentAspect       (),
  25                                 OSG::Thread::getCurrentNamespaceMask(),
  26                                 OSG::Thread::getCurrentLocalFlags   ());
  27
  28     OSG::NodeUnrecPtr pNode1 = OSG::Node::create();
  29
  30     OSG::NodeUnrecPtr pNode2 = OSG::Node::create();
  31     OSG::NodeUnrecPtr pNode3 = OSG::Node::create();
  32
  33     pNode1->addChild(pNode2);
  34     pNode1->addChild(pNode3);
  35
  36     fprintf(stderr, "exit thread\n");
  37
  38     return NULL;
  39 }
  40
  41 void runThread1(void *)
  42 {
  43     fprintf(stderr, "run thread \n");
  44
  45     fprintf(stderr, "th : %p %p %d 0x%016" PRIx64 " 0x%016" PRIx64 "\n",
  46             static_cast<void *>(OSG::Thread::getCurrentChangeList   ()),
  47             static_cast<void *>(OSG::Thread::getCurrent             ()),
  48                                 OSG::Thread::getCurrentAspect       (),
  49                                 OSG::Thread::getCurrentNamespaceMask(),
  50                                 OSG::Thread::getCurrentLocalFlags   ());
  51
  52     fprintf(stderr, "th : %p %p %d 0x%016" PRIx64 " 0x%016" PRIx64 "\n",
  53             static_cast<void *>(OSG::Thread::getCurrentChangeList   ()),
  54             static_cast<void *>(OSG::Thread::getCurrent             ()),
  55                                 OSG::Thread::getCurrentAspect       (),
  56                                 OSG::Thread::getCurrentNamespaceMask(),
  57                                 OSG::Thread::getCurrentLocalFlags   ());
  58
  59     OSG::NodeUnrecPtr pNode1 = OSG::Node::create();
  60
  61     OSG::NodeUnrecPtr pNode2 = OSG::Node::create();
  62     OSG::NodeUnrecPtr pNode3 = OSG::Node::create();
  63
  64     pNode1->addChild(pNode2);
  65     pNode1->addChild(pNode3);
  66
  67     fprintf(stderr, "exit thread\n");
  68 }
  69
  70 int main (int argc, char **argv)
  71 {
  72     OSG::osgInit(argc, argv);
  73
  74 #ifdef OSG_ENABLE_AUTOINIT_THREADS
  75     OSG::Thread::setFallbackAspectId(42);
  76 #endif
  77
  78 #ifdef OSG_ENABLE_AUTOINIT_THREADS
  79     pthread_create(&oThread, NULL, runThread, NULL);
  80
  81     pthread_join(oThread, NULL);
  82 #endif
  83
  84 #if 1
  85     OSG::ThreadRefPtr pThread = OSG::Thread::get(NULL, false);
  86
  87     pThread->runFunction(runThread1, 0, NULL);
  88
  89     OSG::Thread::join(pThread);
  90
  91     pThread = NULL;
  92 #endif
  93     OSG::osgExit();
  94
  95     return 0;
  96 }
  97
  98 #endif
  99
 100 #ifdef OSG_USE_WINTHREADS
 101
 102 OSG::Handle oThread;
 103
 104 void *runThread(void *)
 105 {
 106     fprintf(stderr, "run thread \n");
 107
 108 #if 1
 109     fprintf(stderr, "%d ",
 110             OSG::Thread::getCurrentAspect       ());
 111
 112     fprintf(stderr, "th : T:%p ",
 113             static_cast<void *>(OSG::Thread::getCurrent             ()));
 114     fprintf(stderr, "CL:%p ",
 115             static_cast<void *>(OSG::Thread::getCurrentChangeList   ()));
 116
 117     fprintf(stderr, "0x%016" PRIx64 " ",
 118             OSG::Thread::getCurrentNamespaceMask());
 119
 120     fprintf(stderr, "0x%016" PRIx64 "\n",
 121             OSG::Thread::getCurrentLocalFlags   ());
 122
 123     OSG::NodeUnrecPtr pNode1 = OSG::Node::create();
 124
 125     OSG::NodeUnrecPtr pNode2 = OSG::Node::create();
 126     OSG::NodeUnrecPtr pNode3 = OSG::Node::create();
 127
 128     pNode1->addChild(pNode2);
 129     pNode1->addChild(pNode3);
 130 #endif
 131
 132     fprintf(stderr, "exit thread\n");
 133
 134     return NULL;
 135 }
 136
 137 void runThread1(void *)
 138 {
 139     fprintf(stderr, "run thread \n");
 140
 141     fprintf(stderr, "th : CL:%p T:%p %d 0x%016" PRIx64 " 0x%016" PRIx64 "\n",
 142             static_cast<void *>(OSG::Thread::getCurrentChangeList   ()),
 143             static_cast<void *>(OSG::Thread::getCurrent             ()),
 144                                 OSG::Thread::getCurrentAspect       (),
 145                                 OSG::Thread::getCurrentNamespaceMask(),
 146                                 OSG::Thread::getCurrentLocalFlags   ());
 147
 148     fprintf(stderr, "th : CL:%p T:%p %d 0x%016" PRIx64 " 0x%016" PRIx64 "\n",
 149             static_cast<void *>(OSG::Thread::getCurrentChangeList   ()),
 150             static_cast<void *>(OSG::Thread::getCurrent             ()),
 151                                 OSG::Thread::getCurrentAspect       (),
 152                                 OSG::Thread::getCurrentNamespaceMask(),
 153                                 OSG::Thread::getCurrentLocalFlags   ());
 154
 155     OSG::NodeUnrecPtr pNode1 = OSG::Node::create();
 156
 157     OSG::NodeUnrecPtr pNode2 = OSG::Node::create();
 158     OSG::NodeUnrecPtr pNode3 = OSG::Node::create();
 159
 160     pNode1->addChild(pNode2);
 161     pNode1->addChild(pNode3);
 162
 163     fprintf(stderr, "exit thread\n");
 164 }
 165
 166 int main (int argc, char **argv)
 167 {
 168     OSG::osgInit(argc, argv);
 169
 170 #ifdef OSG_ENABLE_AUTOINIT_THREADS
 171     OSG::Thread::setFallbackAspectId(42);
 172 #endif
 173
 174 #ifdef OSG_ENABLE_AUTOINIT_THREADS
 175     OSG::DWord  tmp;
 176
 177     OSG::Handle rc = CreateThread(NULL,
 178                                   0,
 179                                   (LPTHREAD_START_ROUTINE) runThread,
 180                                   0,
 181                                   0,
 182                                   &tmp);
 183
 184     WaitForSingleObject(rc, INFINITE);
 185 #endif
 186
 187 #if 1
 188     OSG::ThreadRefPtr pThread = OSG::Thread::get(NULL, false);
 189
 190     pThread->runFunction(runThread1, 0, NULL);
 191
 192     OSG::Thread::join(pThread);
 193
 194     pThread = NULL;
 195 #endif
 196     OSG::osgExit();
 197
 198     return 0;
 199 }
 200
 201 #endif