#include<boost/thread.hpp>
#include<boost/chrono.hpp>
#include<iostream>
#include<exception>

using namespace std;

void worker(int tid) {
	try {
	while(true){
	    boost::this_thread::interruption_point();
	    boost::this_thread::sleep_for(boost::chrono::milliseconds(100));
	    }
	   } catch(...) {
	    cout << "Thread: "<<tid <<" interrupted "<<endl;
	               }
	              }
int main(){
	boost::thread_group tg;
	int count;

	try{
	while(true){
		tg.create_thread(boost::bind(worker,count)); 
		count++; 
		   }
	
        }catch(exception &e){
	   cout<<"Exception: " <<e.what() <<endl;
	   cout<<"Max count= "<<count <<endl;
                            }
	tg.interrupt_all();
	tg.join_all();
          }