Changeset 4462 for trunk/compiler

Timestamp:

08/31/08 10:12:04 (4 months ago)

Author:

pmoura

Message:

Simplified implementation of the asynchrounous built-in multi-threading predicates.

Files:

• trunk/compiler/logtalk.pl (modified) (3 diffs)

trunk/compiler/logtalk.pl

@@ -13171 +13171 @@
 '$lgt_mt_dispatch_goal'(call, Queue, Goal, This, Self, Tag) :-
     thread_create('$lgt_mt_non_det_goal'(Queue, Goal, This, Self, Tag), Id, []),
-    % wait until the thread created for proving the goal is ready before proceeding:
-    thread_get_message(Queue, '$lgt_non_det_ready'(Id)).
+    thread_send_message(Queue, '$lgt_thread_id'(call, Goal, This, Self, Tag, Id)).
 
 '$lgt_mt_dispatch_goal'(once, Queue, Goal, This, Self, Tag) :-
     thread_create('$lgt_mt_det_goal'(Queue, Goal, This, Self, Tag), Id, []),
-    % wait until the thread created for proving the goal is ready before proceeding:
-    thread_get_message(Queue, '$lgt_det_ready'(Id)).
+    thread_send_message(Queue, '$lgt_thread_id'(once, Goal, This, Self, Tag, Id)).
 
 
@@ -13187 +13185 @@
 '$lgt_mt_det_goal'(Queue, Goal, This, Self, Tag) :-
     thread_self(Id),
-    thread_send_message(Queue, '$lgt_thread_id'(once, Goal, This, Self, Tag, Id)),
-    % signal that the thread running the goal is ready:
-    thread_send_message(Queue, '$lgt_det_ready'(Id)),
     (   catch(Goal, Error, thread_send_message(Queue, '$lgt_reply'(Goal, This, Self, Tag, Error, Id))) ->
         (   var(Error) ->
@@ -13207 +13202 @@
 '$lgt_mt_non_det_goal'(Queue, Goal, This, Self, Tag) :-
     thread_self(Id),
-    thread_send_message(Queue, '$lgt_thread_id'(call, Goal, This, Self, Tag, Id)),
-    % signal that the thread running the goal is ready:
-    thread_send_message(Queue, '$lgt_non_det_ready'(Id)),
     (   catch(Goal, Error, thread_send_message(Queue, '$lgt_reply'(Goal, This, Self, Tag, Error, Id))),
         (   var(Error) ->