:- initialization(main).
:- dynamic(msg/2).

threads(8).

main :-
	message_queue_create(_, [alias(foo)]),
	threads(THREADS),
	between(1, THREADS, I),
		atomic_concat(foo, I, Alias),
		format("Starting ~w~n", [I]),
		thread_create(thread_run(I), _, [alias(Alias)]),
		fail.
main :-
	threads(THREADS),
	thread_self(Self),
	between(1, THREADS, I),
		atomic_concat(foo, I, Alias),
		Msg = msg(Alias, from(Self)),
		format(" ...Sending1 ~w ~w~n", [I, Msg]),
		assertz(Msg),
		thread_send_message(Alias, Msg),
		fail.
main :-
	threads(THREADS),
	between(1, THREADS, I),
		format("Getting1 ~w~n", [I]),
		thread_get_message(foo, Msg),
		format("... got ~w ~w~n", [I,Msg]),
		fail.
main :-
	threads(THREADS),
	thread_self(Self),
	between(1, THREADS, I),
		atomic_concat(foo, I, Alias),
		Msg = msg(Alias, from(Self)),
		format(" ...Sending2 ~w ~w~n", [I, Msg]),
		assertz(Msg),
		thread_send_message(Alias, Msg),
		fail.
main :-
	threads(THREADS),
	between(1, THREADS, I),
		format("Getting2 ~w~n", [I]),
		thread_get_message(foo, Msg),
		format("... got ~w ~w~n", [I,Msg]),
		fail.
main :-
	threads(THREADS),
	between(1, THREADS, I),
		atomic_concat(foo, I, Alias),
		format("Joining ~w~n", [I]),
		thread_join(Alias,_),
		fail.
main :-
	message_queue_destroy(foo),
	writeln(done).

thread_run(I) :-
	atomic_concat(foo, I, Alias),
	format(" ...Thread ~w~n", [I]),
	between(1,2,_),
		thread_get_message(Msg),
		format(" ...Got ~w got ~w~n", [I, Msg]),
		Msg = msg(_, from(Chan)),
		Msg2 = msg(Alias, from(_)),
		retract(Msg2),
		thread_send_message(foo, ok),
		fail.
thread_run(I) :-
	format("Terminating ~w~n", [I]).