scripting::ThreadQueue Class Reference

Keeps a list of SquirrelThreads that wait for a wakeup event. More...

#include <thread_queue.hpp>

List of all members.

Public Member Functions
	ThreadQueue ()
virtual	~ThreadQueue ()
void	add (HSQUIRRELVM vm)
	adds a thread (actually a weakref to the thread)
void	wakeup ()
	wakes up threads in the list
Private Types
typedef std::vector< HSQOBJECT >	ThreadList
Private Attributes
ThreadList	threads

---

Detailed Description

Keeps a list of SquirrelThreads that wait for a wakeup event.

Definition at line 28 of file thread_queue.hpp.

---

Member Typedef Documentation

typedef std::vector<HSQOBJECT> scripting::ThreadQueue::ThreadList [private]

Definition at line 40 of file thread_queue.hpp.

---

Constructor & Destructor Documentation

scripting::ThreadQueue::ThreadQueue

(

)

Definition at line 25 of file thread_queue.cpp.

                         :
  threads()
{
}

scripting::ThreadQueue::~ThreadQueue

(

)

[virtual]

Definition at line 30 of file thread_queue.cpp.

{
}

---

Member Function Documentation

void scripting::ThreadQueue::add

(

HSQUIRRELVM

vm

)

adds a thread (actually a weakref to the thread)

Definition at line 35 of file thread_queue.cpp.

References scripting::global_vm, threads, and scripting::vm_to_object().

Referenced by scripting::wait_for_screenswitch().

{
  // create a weakref to the VM
  HSQOBJECT vm_obj = vm_to_object(vm);
  sq_pushobject(global_vm, vm_obj);
  sq_weakref(global_vm, -1);

  HSQOBJECT object;
  if(SQ_FAILED(sq_getstackobj(global_vm, -1, &object))) {
    sq_pop(global_vm, 2);
    throw SquirrelError(global_vm, "Couldn't get thread weakref from vm");
  }
  sq_addref(global_vm, &object);
  threads.push_back(object);

  sq_pop(global_vm, 2);
}

void scripting::ThreadQueue::wakeup

(

)

wakes up threads in the list

Definition at line 54 of file thread_queue.cpp.

References scripting::global_vm, log_warning, and threads.

Referenced by ScreenManager::handle_screen_switch().

{
  // we traverse the list in reverse orders and use indices. This should be
  // robust for scripts that add new entries to the list while we're traversing
  // it
  size_t i = threads.size() - 1;
  size_t end = (size_t) 0 - 1;
  size_t size_begin = threads.size();
  while(i != end) {
    HSQOBJECT object = threads[i];

    sq_pushobject(global_vm, object);
    sq_getweakrefval(global_vm, -1);

    HSQUIRRELVM scheduled_vm;
    if(sq_gettype(global_vm, -1) == OT_THREAD &&
       SQ_SUCCEEDED(sq_getthread(global_vm, -1, &scheduled_vm))) {
      if(SQ_FAILED(sq_wakeupvm(scheduled_vm, SQFalse, SQFalse, SQTrue, SQFalse))) {
        log_warning << "Couldn't wakeup scheduled squirrel VM" << std::endl;
      }
    }

    sq_release(global_vm, &object);
    sq_pop(global_vm, 1);
    i--;
  }

  threads.erase(threads.begin(), threads.begin() + size_begin);
}

---

Member Data Documentation

ThreadList scripting::ThreadQueue::threads [private]

Definition at line 41 of file thread_queue.hpp.

Referenced by add(), and wakeup().

---

The documentation for this class was generated from the following files:

• src/scripting/thread_queue.hpp
• src/scripting/thread_queue.cpp

---