thread1.c

00001 /*
00002  * Copyright (c) 2005 Jakub Vana
00003  * Copyright (c) 2005 Jakub Jermar
00004  * All rights reserved.
00005  *
00006  * Redistribution and use in source and binary forms, with or without
00007  * modification, are permitted provided that the following conditions
00008  * are met:
00009  *
00010  * - Redistributions of source code must retain the above copyright
00011  *   notice, this list of conditions and the following disclaimer.
00012  * - Redistributions in binary form must reproduce the above copyright
00013  *   notice, this list of conditions and the following disclaimer in the
00014  *   documentation and/or other materials provided with the distribution.
00015  * - The name of the author may not be used to endorse or promote products
00016  *   derived from this software without specific prior written permission.
00017  *
00018  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
00019  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
00020  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
00021  * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
00022  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
00023  * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
00024  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
00025  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
00026  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
00027  * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
00028  */
00029 
00030 #define THREADS  20
00031 #define DELAY    10
00032 
00033 #include <atomic.h>
00034 #include <thread.h>
00035 #include <stdio.h>
00036 #include <unistd.h>
00037 #include <inttypes.h>
00038 #include "../tester.h"
00039 
00040 static atomic_t finish;
00041 static atomic_t threads_finished;
00042 
00043 static void threadtest(void *data)
00044 {
00045         thread_detach(thread_get_id());
00046         
00047         while (atomic_get(&finish))
00048                 usleep(100000);
00049         
00050         atomic_inc(&threads_finished);
00051 }
00052 
00053 const char *test_thread1(void)
00054 {
00055         unsigned int i;
00056         atomic_count_t total = 0;
00057         
00058         atomic_set(&finish, 1);
00059         atomic_set(&threads_finished, 0);
00060         
00061         TPRINTF("Creating threads");
00062         for (i = 0; i < THREADS; i++) {
00063                 if (thread_create(threadtest, NULL, "threadtest", NULL) < 0) {
00064                         TPRINTF("\nCould not create thread %u\n", i);
00065                         break;
00066                 }
00067                 TPRINTF(".");
00068                 total++;
00069         }
00070         
00071         TPRINTF("\nRunning threads for %u seconds...", DELAY);
00072         sleep(DELAY);
00073         TPRINTF("\n");
00074         
00075         atomic_set(&finish, 0);
00076         while (atomic_get(&threads_finished) < total) {
00077                 TPRINTF("Threads left: %" PRIua "\n",
00078                     total - atomic_get(&threads_finished));
00079                 sleep(1);
00080         }
00081         
00082         return NULL;
00083 }

Generated on Thu Jun 2 07:45:43 2011 for HelenOS/USB by  doxygen 1.4.7