threadtest.cc

Go to the documentation of this file.

// threadtest.cc
//      Simple test case for the threads assignment.
//
//
// Copyright (c) 1992-1993 The Regents of the University of California.
// All rights reserved.  See copyright.h for copyright notice and limitation
// of liability and disclaimer of warranty provisions.

#include "copyright.h"
#include "system.h"
#include "synch.h"
#include <time.h>
#include "list.h"

Semaphore  SPing("Ping", 1);
Semaphore  SPong("Pong", 0);


void Ping(int ch)
{
        printf("Ping Start\n");
        for(int i = 0; i < 10; i++)
        {
                SPing.P();
                printf("Ping\n");
                SPong.V();
        }
} /* Ping */


void Pong(int ch)
{
        printf("Pong Start\n");
        for(int i = 0; i < 10; i++)
        {
                SPong.P();
                printf("Pong\n");
                SPing.V();
        }
} /* Pong */


void PingPong()
{
        Thread *t1 = new Thread("Ping");
        Thread *t2 = new Thread("Pong");

        t1->Fork(Ping, 0);
        t2->Fork(Pong, 0);
} /* PingPong */



void SimpleThread1(int which)
{
        int num4 = 1;
        int num = 0;
        int count = 0;

        printf("^%c Started\n", which);

        for (num = 0; num < 500; num++)
    {
                for(num4 = 0; num4 < 40000; num4++, count++)
                        ;
                printf("%c", (char)which);
                count++;
    } /* for */

        printf("%c$Done count:%d$\n", which, count);
} /* SimpleThread1 */

//----------------------------------------------------------------------
// ThreadTest
//      Fork 7 threads and call PingPong
//----------------------------------------------------------------------

void ThreadTest1(int arg)
{
    printf("Entering SimpleTest\n");


        Thread *t1 = new Thread("A thread");
        Thread *t2 = new Thread("B thread");
        Thread *t3 = new Thread("C thread");
        Thread *t4 = new Thread("D thread");
        Thread *t5 = new Thread("E thread");
        Thread *t6 = new Thread("F thread");
        Thread *t7 = new Thread("G thread");
    t1->Fork(SimpleThread1, 'A');
        t2->Fork(SimpleThread1, 'B');
        t3->Fork(SimpleThread1, 'C');
        t4->Fork(SimpleThread1, 'D');
        t5->Fork(SimpleThread1, 'E');
        t6->Fork(SimpleThread1, 'F');
        t7->Fork(SimpleThread1, 'G');

        printf("Doing Ping Pong\n");
        PingPong();
} /* ThreadTest1 */

---