FilesExpand file tree

 master

/

thread_pool.cpp

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

68 lines (61 loc) · 1.47 KB

 master

/

thread_pool.cpp

Copy path

Top

File metadata and controls

• Code
• Blame

68 lines (61 loc) · 1.47 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

// Copyright (C) 2012-2013 Vicente Botet

//

// 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)

#define BOOST_THREAD_VERSION 4

#define BOOST_THREAD_USES_LOG

#define BOOST_THREAD_USES_LOG_THREAD_ID

#define BOOST_THREAD_QUEUE_DEPRECATE_OLD

#include <boost/thread/detail/log.hpp>

#include <boost/thread/executors/basic_thread_pool.hpp>

#include <boost/assert.hpp>

#include <string>

void p1()

{

BOOST_THREAD_LOG

<< boost::this_thread::get_id() << " P1" << BOOST_THREAD_END_LOG;

}

void p2()

{

BOOST_THREAD_LOG

<< boost::this_thread::get_id() << " P2" << BOOST_THREAD_END_LOG;

}

void submit_some(boost::basic_thread_pool& tp) {

tp.submit(&p1);

tp.submit(&p2);

tp.submit(&p1);

tp.submit(&p2);

tp.submit(&p1);

tp.submit(&p2);

tp.submit(&p1);

tp.submit(&p2);

tp.submit(&p1);

tp.submit(&p2);

}

int main()

{

BOOST_THREAD_LOG

<< boost::this_thread::get_id() << " <MAIN" << BOOST_THREAD_END_LOG;

{

try

{

boost::basic_thread_pool tp;

submit_some(tp);

}

catch (std::exception& ex)

{

BOOST_THREAD_LOG

<< "ERRORRRRR " << ex.what() << "" << BOOST_THREAD_END_LOG;

return 1;

}

catch (...)

{

BOOST_THREAD_LOG

<< " ERRORRRRR exception thrown" << BOOST_THREAD_END_LOG;

return 2;

}

}

BOOST_THREAD_LOG

<< boost::this_thread::get_id() << "MAIN>" << BOOST_THREAD_END_LOG;

return 0;

}