repos/GoogleTron/GoogleTron.hpp

// Google Tron
//
// Douglas Thrift
//
// $Id$

#ifndef _GoogleTron_hpp_
#define _GoogleTron_hpp_

#include <cxx/platform.hpp>

#ifdef MENES_PRAGMA_ONCE
#pragma once
#endif

#include <api/threads.hpp>
#include <api/locks.hpp>
#include <mta/threadset.hpp>

#include <queue> // XXX: no ext::Queue yet :(

#include "Url.hpp"

class GoogleTron
{
        bool working;
        const cse::String &sitemap;
        // XXX: I want ext::Queue!
        std::queue<Url> queue;
        api::ThreadMutex queueLock;
        _S<api::Thread> output;
        mta::ThreadSet<> threads;
        int Output();
public:
        GoogleTron(const cse::String &sitemap);
        ~GoogleTron();
};

#endif//_GoogleTron_hpp_
Revision:	681
Committed:	2006-03-06T02:00:10-08:00 (19 years, 4 months ago) by douglas
File size:	628 byte(s)
Log Message:	Stackallocate!
#	Content
1	// Google Tron
2	//
3	// Douglas Thrift
4	//
5	// $Id$
6
7	#ifndef _GoogleTron_hpp_
8	#define _GoogleTron_hpp_
9
10	#include <cxx/platform.hpp>
11
12	#ifdef MENES_PRAGMA_ONCE
13	#pragma once
14	#endif
15
16	#include <api/threads.hpp>
17	#include <api/locks.hpp>
18	#include <mta/threadset.hpp>
19
20	#include <queue> // XXX: no ext::Queue yet :(
21
22	#include "Url.hpp"
23
24	class GoogleTron
25	{
26	bool working;
27	const cse::String &sitemap;
28	// XXX: I want ext::Queue!
29	std::queue<Url> queue;
30	api::ThreadMutex queueLock;
31	_S<api::Thread> output;
32	mta::ThreadSet<> threads;
33	int Output();
34	public:
35	GoogleTron(const cse::String &sitemap);
36	~GoogleTron();
37	};
38
39	#endif//_GoogleTron_hpp_