libstdc++-v3/testsuite/23_containers/list/pthread5.cc

   1 // 2002-01-23  Loren J. Rittle <rittle@labs.mot.com> <ljrittle@acm.org>
   2 // Adpated from libstdc++/5464 submitted by jjessel@amadeus.net
   3 // Jean-Francois JESSEL (Amadeus SAS Development)
   4 //
   5 // Copyright (C) 2002-2024 Free Software Foundation, Inc.
   6 //
   7 // This file is part of the GNU ISO C++ Library.  This library is free
   8 // software; you can redistribute it and/or modify it under the
   9 // terms of the GNU General Public License as published by the
  10 // Free Software Foundation; either version 3, or (at your option)
  11 // any later version.
  12 //
  13 // This library is distributed in the hope that it will be useful,
  14 // but WITHOUT ANY WARRANTY; without even the implied warranty of
  15 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  16 // GNU General Public License for more details.
  17 //
  18 // You should have received a copy of the GNU General Public License along
  19 // with this library; see the file COPYING3.  If not see
  20 // <http://www.gnu.org/licenses/>.
  21
  22 // { dg-do run }
  23 // { dg-options "-pthread"  }
  24 // { dg-require-effective-target pthread }
  25
  26 #include <vector>
  27 #include <list>
  28 #include <string>
  29 #include <cstdlib>
  30 #include <pthread.h>
  31
  32 #ifdef _GLIBCXX_HAVE_UNISTD_H
  33 #include <unistd.h>     // To test for _POSIX_THREAD_PRIORITY_SCHEDULING
  34 #endif
  35
  36 #define NTHREADS 8
  37 #define LOOPS 20
  38
  39 struct tt_t
  40 {
  41   char buf[100];
  42   int  i;
  43 };
  44
  45 void*
  46 thread_function (void* arg)
  47 {
  48   typedef std::vector<tt_t>             vector_type;
  49   typedef std::list<std::string*>       list_type;
  50
  51   int myid __attribute__((unused)) = *(int*) arg;
  52   for (int i = 0; i < LOOPS; i++)
  53     {
  54       vector_type myvect1;
  55
  56       for (int j = 0; j < 2000; j++)
  57         {
  58           vector_type myvect2;
  59           tt_t v;
  60           v.i = j;
  61           myvect1.push_back (v);
  62           myvect2.push_back (v);
  63           list_type mylist;
  64           std::string string_array[4];
  65           string_array[0] = "toto";
  66           string_array[1] = "titi";
  67           string_array[2] = "tata";
  68           string_array[3] = "tutu";
  69           for (int k = 0; k < 4; k++)
  70             {
  71               if (mylist.size ())
  72                 {
  73                   list_type::iterator aIt;
  74                   for (aIt = mylist.begin (); aIt != mylist.end (); ++aIt)
  75                     {
  76                       if ((*aIt) == &(string_array[k]))
  77                         abort ();
  78                     }
  79                 }
  80               mylist.push_back (&(string_array[k]));
  81             }
  82         }
  83     }
  84
  85   return arg;
  86 }
  87
  88 int
  89 main ()
  90 {
  91   int worker;
  92   pthread_t threads[NTHREADS];
  93   int ids[NTHREADS];
  94   void* status;
  95
  96 #if defined(__sun) && defined(__svr4__) && _XOPEN_VERSION >= 500
  97   pthread_setconcurrency (NTHREADS);
  98 #endif
  99
 100   pthread_attr_t tattr;
 101   int ret __attribute__((unused)) = pthread_attr_init (&tattr);
 102 #ifdef _POSIX_THREAD_PRIORITY_SCHEDULING
 103   ret = pthread_attr_setscope(&tattr, PTHREAD_SCOPE_SYSTEM);
 104 #endif
 105
 106   for (worker = 0; worker < NTHREADS; worker++)
 107     {
 108       ids[worker] = worker;
 109       if (pthread_create(&threads[worker], &tattr,
 110                          thread_function, &ids[worker]))
 111         abort ();
 112     }
 113
 114   for (worker = 0; worker < NTHREADS; worker++)
 115     {
 116       if (pthread_join(threads[worker], static_cast<void **>(&status)))
 117         abort ();
 118
 119       if (*((int *)status) != worker)
 120         abort ();
 121     }
 122
 123   return (0);
 124 }