📌 Nodepp | Atomicity update | V1.3.2 📌

Author: EDBCREPO

include/nodepp/atomic.h

@@ -24,4 +24,11 @@
 
 /*────────────────────────────────────────────────────────────────────────────*/
 
+namespace nodepp {
+    atomic_t<bool> _EXIT_( false  );
+    atomic_t<int>  _TASK_( int(0) );
+}
+
+/*────────────────────────────────────────────────────────────────────────────*/
+
 #endif

include/nodepp/import.h

@@ -24,6 +24,11 @@
 
 #include "macros.h"
 #include "type.h"
+#include "atomic.h"
+
+/*────────────────────────────────────────────────────────────────────────────*/
+
+#include "ptr.h"
 #include "ref.h"
 
 /*────────────────────────────────────────────────────────────────────────────*/

include/nodepp/macros.h

@@ -88,11 +88,6 @@ template< class T > T clamp( const T& val, const T& _min, const T& _max ){ retur
 
 /*────────────────────────────────────────────────────────────────────────────*/
 
-bool    _EXIT_ = false;
-int     _TASK_ = 0;
-
-/*────────────────────────────────────────────────────────────────────────────*/
-
 #define forEach( X, ITEM ) for( auto& X : ITEM )
 #define forEver() for (;;)
 #define elif else if

include/nodepp/nodepp.h

@@ -26,9 +26,9 @@ namespace nodepp { namespace process {
 
     /*─······································································─*/
 
-    inline ulong size(){ return _TASK_ + _loop_.size() + _poll_.size() + _foop_.size(); }
+    inline ulong size(){ return _TASK_.get() + _loop_.size() + _poll_.size() + _foop_.size(); }
 
-    inline void clear(){ _TASK_=0; _loop_.clear(); _poll_.clear(); _foop_.clear(); }
+    inline void clear(){ _TASK_.set(0); _loop_.clear(); _poll_.clear(); _foop_.clear(); }
 
     inline bool empty(){ return size() <= 0; }
 

include/nodepp/posix/worker.h

@@ -17,23 +17,22 @@
 namespace nodepp { class worker_t { 
 private:
 
-    struct waiter { bool blk; bool out; }; 
+    mutex_t& mut(){ static mutex_t mut; return mut; }
+    struct waiter { bool blk; bool out; };
 
 protected:
 
     struct NODE {
         function_t<int> cb;
         bool* out, state=0;
         pthread_t /*-*/ id;
-        mutex_t /*--*/ mtx;
     };  ptr_t<NODE> obj;
 
     static void* callback( void* arg ){
-        auto self = type::cast<worker_t>(arg);
-        self->obj->mtx.emit([=](){ self->obj->state=1; return -1; });
+        auto self = type::cast<worker_t>(arg); self->obj->state=1;
         while( self->obj->cb.emit() >= 0 ){ worker::yield(); } 
-        self->obj->mtx.emit([=](){ self->free(); return -1; });
-        /*-------*/ delete self; worker::exit(); 
+        self->mut().emit([=](){ self->free(); return -1; });
+        /*----*/ delete self; worker::exit(); 
     return nullptr; }
 
 public:

include/nodepp/ptr.h

@@ -17,7 +17,7 @@
 namespace nodepp { template< class T > class ptr_t {
 private:
 
-    struct NODE { ulong count, length; T* value; };
+    struct NODE { atomic_t<ulong> count, length; T* value; };
 
     inline int _free_( NODE* address ) const noexcept {
         if( address /*--*/ == nullptr ){ return -1; }
@@ -204,8 +204,8 @@ namespace nodepp { template< class T > class ptr_t {
 
     /*─······································································─*/
 
-    ulong     size() const noexcept { return null() ? 0 /*-*/ : address->length; }
-    ulong    count() const noexcept { return null() ? 0 /*-*/ : address->count;  }
+    ulong     size() const noexcept { return null() ? 0 /*-*/ : address->length.get(); }
+    ulong    count() const noexcept { return null() ? 0 /*-*/ : address->count .get(); }
 
     T*        data() const noexcept { return null() ? nullptr : address->value;  }
     T*         get() const noexcept { return null() ? nullptr : address->value;  }
@@ -233,4 +233,16 @@ namespace nodepp { template< class T > class ptr_t {
 
 /*────────────────────────────────────────────────────────────────────────────*/
 
+namespace nodepp { namespace type {
+
+    template< class T, class V > T* cast( ptr_t<V>& object ){ if( object==nullptr ){ return nullptr; } return static_cast<T*>(object.get()); }
+    
+    template<class T> ptr_t<T> bind( ptr_t<T>& object ){ if( object==nullptr ){ return nullptr; } return    object.copy(); }
+    template<class T> ptr_t<T> bind(       T*  object ){ if( object==nullptr ){ return nullptr; } return new T( *object ); }
+    template<class T> ptr_t<T> bind(       T   object ){ return new T( object ); }
+
+}}
+
+/*────────────────────────────────────────────────────────────────────────────*/
+
 #endif

include/nodepp/type.h

@@ -14,6 +14,15 @@
 
 /*────────────────────────────────────────────────────────────────────────────*/
 
+namespace nodepp { namespace type {
+
+    template< class T, class V > T* cast( V* object ){ if( object==nullptr ){ return nullptr; } return static_cast<T*>(object); }
+    template< class T, class V > T  cast( V  object ){ return static_cast<T>( object ); }
+
+}}
+
+/*────────────────────────────────────────────────────────────────────────────*/
+
 namespace nodepp { namespace type {
 
     struct false_type { static constexpr bool value = false; using type = false_type; };
@@ -409,22 +418,4 @@ namespace nodepp { namespace type {
 
 /*────────────────────────────────────────────────────────────────────────────*/
 
-#include "ptr.h"
-
-/*────────────────────────────────────────────────────────────────────────────*/
-
-namespace nodepp { namespace type {
-
-    template< class T, class V > T* cast( ptr_t<V>& object ){ if( object==nullptr ){ return nullptr; } return static_cast<T*>(object.get()); }
-    template< class T, class V > T* cast(       V*  object ){ if( object==nullptr ){ return nullptr; } return static_cast<T*>(object); }
-    template< class T, class V > T  cast(       V   object ){ return static_cast<T>( object ); }
-
-    template<class T> ptr_t<T>      bind( ptr_t<T>& object ){ if( object==nullptr ){ return nullptr; } return    object.copy(); }
-    template<class T> ptr_t<T>      bind(       T*  object ){ if( object==nullptr ){ return nullptr; } return new T( *object ); }
-    template<class T> ptr_t<T>      bind(       T   object ){ return new T( object ); }
-
-}}
-
-/*────────────────────────────────────────────────────────────────────────────*/
-
 #endif

include/nodepp/windows/worker.h

@@ -17,6 +17,7 @@
 namespace nodepp { class worker_t { 
 private:
 
+    mutex_t& mut(){ static mutex_t mut; return mut; }
     struct waiter { bool blk; bool out; }; 
 
 protected:
@@ -26,15 +27,13 @@ namespace nodepp { class worker_t {
         HANDLE /**/ thread;
         bool *out, state=0;
         DWORD /*-----*/ id; 
-        mutex_t /*--*/ mtx;
     };  ptr_t<NODE> obj;
 
     static DWORD WINAPI callback( LPVOID arg ){
-        auto self = type::cast<worker_t>(arg);
-        self->obj->mtx.emit([=](){ self->obj->state=1; return -1; });
-        while( self->obj->cb.emit() >= 0 ){ worker::yield(); } 
-        self->obj->mtx.emit([=](){ self->free(); return -1; });
-        /*-------*/ delete self; worker::exit(); 
+        auto self = type::cast<worker_t>(arg); self->obj->state=1;
+        while( self->obj->cb.emit() >= 0 ){ worker::yield(); }
+        self->mut().emit([=](){ self->free(); return -1; });
+        /*----*/ delete self; worker::exit(); 
     return 0; }
 
 public: