File contents

/*ident	"@(#)cls4:demo/task/alph.C	1.1" */
/*******************************************************************************
 
C++ source for the C++ Language System, Release 3.0.  This product
is a new release of the original cfront developed in the computer
science research center of AT&T Bell Laboratories.

Copyright (c) 1991 AT&T and UNIX System Laboratories, Inc.
Copyright (c) 1984, 1989, 1990 AT&T.  All Rights Reserved.

THIS IS UNPUBLISHED PROPRIETARY SOURCE CODE of AT&T and UNIX System
Laboratories, Inc.  The copyright notice above does not evidence
any actual or intended publication of such source code.

*******************************************************************************/
// Demonstration of two tasks communicating via semaphores.

#include <task.h>
#define K 10

class Semaphore : public object {
	int	sigs;
public:
		Semaphore(int i =0) { sigs = i; }
	int	pending();
	void	wait();
	void	signal() { if (sigs++ == 0) alert(); }
};

void
Semaphore::wait()
{
	for (;;) {
		if (--sigs >= 0)
			return;
		sigs++;
		this_task()->sleep(this);
	}
}

int
Semaphore::pending()
{
	return sigs <= 0;
}

class Test : public task
{
public:
		Test(int);
};

Semaphore* sema[2];

Test::Test(int i)
: task(i ? "Alphonse" : "Gaston")
{
	for (register int n = K / 2; n--; ) {
		sema[!i]->wait();
		sema[i]->signal();
		printf("%s: %d\n", i ? "Alphonse" : "Gaston", n);
	}
	resultis(0);	// always terminate with resultis;
			// "return" or coming to end of function is undefined.
}

main()
{
	sema[0] = new Semaphore(1);
	sema[1] = new Semaphore;
	new Test(0);	// create "Gaston" task; switch to it
	new Test(1);	// create "Alphonse" task; switch to it
	((object*)0)->this_task()->resultis(0); // terminate main task
}