Changes in / [a3f5208a:c28ea4e]

File:

• libcfa/src/concurrency/preemption.cfa (modified) (1 diff)

libcfa/src/concurrency/preemption.cfa

@@ -105 +105 @@
 
                 // Check if this is a kernel
-                if( node->kernel_alarm ) {
+                if( node->type == Kernel ) {
                         preempt( node->proc );
                 }
+                else if( node->type == User ) {
+                        timeout( node->thrd );
+                }
                 else {
-                        timeout( node->thrd );
+                        bool unpark_thd = node->callback(*node);
+                        if (unpark_thd) timeout( node->thrd );
                 }