FilesExpand file tree

 develop

/

user_scheduler.cpp

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

79 lines (71 loc) · 1.74 KB

 develop

/

user_scheduler.cpp

Copy path

Top

File metadata and controls

• Code
• Blame

79 lines (71 loc) · 1.74 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

69

70

71

72

73

74

75

76

77

78

79

// Copyright (C) 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)

#include <boost/config.hpp>

#define BOOST_THREAD_VERSION 4

//#define BOOST_THREAD_USES_LOG

#define BOOST_THREAD_USES_LOG_THREAD_ID

#if ! defined BOOST_NO_CXX11_DECLTYPE

#define BOOST_RESULT_OF_USE_DECLTYPE

#endif

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

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

#include <boost/assert.hpp>

#include <boost/thread/thread_only.hpp>

#include <string>

#ifdef BOOST_MSVC

#pragma warning(disable: 4127) // conditional expression is constant

#endif

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::loop_executor& 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::loop_executor tp;

submit_some(tp);

tp.run_queued_closures();

submit_some(tp);

tp.run_queued_closures();

}

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;

}