Работа с потоками

[Rififi]

QuadroX

Что-то типа такого. Можешь выдать преподу за свою :D

#include <string>
#include <queue>

#include <locale>
#include <iostream>
#include <fstream>

#include <boost/thread.hpp>

#include <atlbase.h>

const CHandle hExit(CreateEvent(nullptr, FALSE, FALSE, NULL));
const CHandle hPing(CreateEvent(nullptr, FALSE, FALSE, NULL));

typedef std::queue<std::string> Q;
Q q;

boost::mutex m;
size_t counter = 0;

void Reader(const std::string& fileName)
{
	std::ifstream ifs(fileName);

	std::string s;
	while (std::getline(ifs, s))
	{
		{
			const boost::mutex::scoped_lock l(m);
			q.push(s);
		}

		PulseEvent(hPing);
	}

	SetEvent(hExit);
}

void Counter()
{
	const HANDLE h[] = { hPing, hExit };

	while (1)
	{
		enum { Event_Ping = WAIT_OBJECT_0, Event_Exit };

		DWORD err = WaitForMultipleObjects(_countof(h), h, FALSE, INFINITE);
		if (err == Event_Exit)
			return;

		Q tmp;
		{
			const boost::mutex::scoped_lock l(m);
			tmp.swap(q);
		}

		do
		{
			for ( ; tmp.size(); tmp.pop())
			{
				const std::string s = tmp.front();
				if (s.find("строка для поиска") != std::string::npos)
					counter++;
			}

			const boost::mutex::scoped_lock l(m);
			tmp.swap(q);
		} while (tmp.size());
	}
}

int _tmain(int argc, _TCHAR* argv[])
{
	setlocale(LC_ALL, "");

	boost::thread_group g;

	g.create_thread(boost::bind(&Reader, "file.txt"));
	g.create_thread(&Counter);

	g.join_all();

	std::cout << "Counter: " << counter << std::endl;

	return 0;
}