#include "test.h"
|
|
|
using namespace std;
|
|
SQueue<struct Item> *queue;
|
|
|
void sigint_handler(int sig) {
|
cerr << "sigint_handler" << endl;
|
destroy();
|
exit(0);
|
|
}
|
|
int main(int argc, char *argv[])
|
{
|
void *shmp;
|
string line;
|
signal(SIGINT, sigint_handler);
|
/* Create set containing two semaphores; initialize so that
|
writer has first access to shared memory. */
|
int start = 0;
|
int end = -1;
|
|
if (argc == 3) {
|
start = atoi(argv[1]);
|
end = atoi(argv[2]);
|
}
|
|
int first = mm_init(sizeof(SQueue<struct Item>), &shmp);
|
|
if (first == 1)
|
queue = new(shmp) SQueue<struct Item>(1);
|
else
|
queue = (SQueue<struct Item> *) shmp;
|
|
/* Transfer blocks of data from stdin to shared memory */
|
struct Item item;
|
struct timespec timeout = {5, 0};
|
int i = start;
|
item.pic = i;
|
item.info = i;
|
while((end == -1 || (i < end) ) && (queue->enqueue_timeout(item, &timeout)) ) {
|
item.pic = i;
|
item.info = i;
|
|
// cout << "入队：" << item.pic << ", " << item.info << endl;
|
cout << item.pic << endl;
|
|
i++;
|
|
}
|
|
cerr << "productor quit" << endl;
|
exit(EXIT_SUCCESS);
|
}
|
