compile_all.cpp File Reference

threadpool tutorial. More...

#include <boost/bind.hpp>
#include <boost/thread/mutex.hpp>
#include <iostream>
#include <sstream>
#include <boost/threadpool.hpp>

Include dependency graph for compile_all.cpp:

Go to the source code of this file.

Functions
void	print (string text)
template<typename T >
string	to_string (T const &value)
void	task_1 ()
void	task_2 ()
void	task_3 ()
int	task_4 ()
void	task_with_parameter (int value)
bool	looped_task ()
int	task_int ()
void	fifo_pool_test ()
void	lifo_pool_test ()
void	prio_pool_test ()
void	future_test ()
int	main (int, char *const [])

Variables
boost::mutex	m_io_monitor
int	loops = 0

Detailed Description

threadpool tutorial.

This file contains a tutorial for the threadpool library.

Copyright (c) 2005-2006 Philipp Henkel

Distributed under the Boost Software License, Version 1.0. (See accompanying file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)

http://threadpool.sourceforge.net

Definition in file compile_all.cpp.

Function Documentation

void fifo_pool_test

(

)

Definition at line 74 of file compile_all.cpp.

{
  pool tp;

  tp.schedule( &task_1 );
  tp.schedule( boost::bind( task_with_parameter, 4 ) );

  if ( !tp.empty() ) {
    tp.clear(); // remove all tasks -> no output in this test
  }

  size_t active_threads  = tp.active();
  size_t pending_threads = tp.pending();
  size_t total_threads   = tp.size();

  size_t dummy = active_threads + pending_threads + total_threads;
  dummy++;

  tp.size_controller().resize( 5 );
  tp.wait();
}

void future_test

(

)

Definition at line 112 of file compile_all.cpp.

{
  fifo_pool tp( 5 );
  future<int> fut = schedule( tp, &task_4 );
  int res         = fut();
}

void lifo_pool_test

(

)

Definition at line 96 of file compile_all.cpp.

{
  lifo_pool tp;
  tp.size_controller().resize( 0 );
  schedule( tp, &task_1 );
  tp.size_controller().resize( 10 );
  tp.wait();
}

bool looped_task

(

)

Definition at line 62 of file compile_all.cpp.

{
  print( "  looped_task()\n" );
  return ++loops < 5;
}

int main	(	int	,
		char *	const[]
	)

Definition at line 119 of file compile_all.cpp.

{
  fifo_pool_test();
  lifo_pool_test();
  prio_pool_test();
  future_test();
  return 0;
}

void print

(

string

text

)

Definition at line 30 of file compile_all.cpp.

{
  boost::mutex::scoped_lock lock( m_io_monitor );
  cout << text;
}

void prio_pool_test

(

)

Definition at line 105 of file compile_all.cpp.

{
  prio_pool tp( 2 );
  schedule( tp, prio_task_func( 1, &task_1 ) );
  schedule( tp, prio_task_func( 10, &task_2 ) );
}

void task_1

(

)

Definition at line 47 of file compile_all.cpp.

{ print( "  task_1()\n" ); }

void task_2

(

)

Definition at line 49 of file compile_all.cpp.

{ print( "  task_2()\n" ); }

void task_3

(

)

Definition at line 51 of file compile_all.cpp.

{ print( "  task_3()\n" ); }

int task_4

(

)

Definition at line 53 of file compile_all.cpp.

{
  print( "  task_4()\n" );
  return 4;
}

int task_int

(

)

Definition at line 68 of file compile_all.cpp.

{
  print( "  task_int()\n" );
  return 23;
}

void task_with_parameter

(

int

value

)

Definition at line 59 of file compile_all.cpp.

{ print( "  task_with_parameter(" + to_string( value ) + ")\n" ); }

template<typename T >

string to_string

(

T const &

value

)

Definition at line 37 of file compile_all.cpp.

{
  ostringstream ost;
  ost << value;
  ost.flush();
  return ost.str();
}

Variable Documentation

int loops = 0

Definition at line 61 of file compile_all.cpp.

boost::mutex m_io_monitor

Definition at line 28 of file compile_all.cpp.