程序代码：

#include "InfoStream.h"
#include "charm++.h"
#include "BroadcastMgr.h"
#include "BroadcastClient.h"
#define MIN_DEBUG_LEVEL 3
//define DEBUGM
#include "Debug.h"
BroadcastClient::BroadcastClient(int id) {
    this->id=id;
    BroadcastMgr::Object()->subscribe(*this);
    waitForTag=-1;
    suspended=0;
}
BroadcastClient::~BroadcastClient::() {
    BroadcastMgr::Object()->subscribe(*this);
}

void
BroadcastClient::awaken(int theid,int tag) {
    DebugM(1,"awaken() client id="<<id<<"tag="<<tag<<"\n")
        if (suspended && theid == this->id && tag == waitForTag) {
            CthAwaken(thread);
            suspended = 0; waitForTag = -1;
        }
}
void 
BroadcastClient::suspendFor(int tag) {
   DebugM(1,"suspending() client id ="<<id<<"tag="<<tag<<"\n");
   suspended = 1;
    waitForTag=tag;
    thread = CthSelf();
    CthSuspend();
}