From 4b9289cfb260f4bcecaf23a810584ef6ef8e8501 Mon Sep 17 00:00:00 2001 From: Mike Buland Date: Wed, 30 Mar 2011 22:33:41 +0000 Subject: Ok, string stuff is working much, much better, a load of new unit tests have been added, and I deleted a whole slew of stupid old tests that I don't need. --- src/tests/itoqueue1.cpp | 115 ------------------------------------------------ 1 file changed, 115 deletions(-) delete mode 100644 src/tests/itoqueue1.cpp (limited to 'src/tests/itoqueue1.cpp') diff --git a/src/tests/itoqueue1.cpp b/src/tests/itoqueue1.cpp deleted file mode 100644 index 27cb93c..0000000 --- a/src/tests/itoqueue1.cpp +++ /dev/null @@ -1,115 +0,0 @@ -/* - * Copyright (C) 2007-2011 Xagasoft, All rights reserved. - * - * This file is part of the libbu++ library and is released under the - * terms of the license contained in the file LICENSE. - */ - -#include -#include "bu/ito.h" -#include "bu/itoqueue.h" -#include -#include - -class Reader : public Bu::Ito -{ -public: - Reader( Bu::ItoQueue &q, int id ) : - q( q ), - id( id ) - { - } - - void run() - { - for( int i = 0; i < 10; i++ ) - { - std::string *pStr = q.dequeue( true ); - if( pStr == NULL ) - { - printf("Null received...\n"); - } - else - { - printf("[%d] read: %s\n", id, pStr->c_str() ); - delete pStr; - } - usleep( (int)(((double)rand())/((double)RAND_MAX)*2000000.0) ); - } - } - -private: - Bu::ItoQueue &q; - int id; -}; - -class Writer : public Bu::Ito -{ -public: - Writer( Bu::ItoQueue &q, int id, const char *strbase ) : - q( q ), - strbase( strbase ), - id( id ) - { - } - - void run() - { - for( int i = 0; i < 11; i++ ) - { - usleep( (int)(((double)rand())/((double)RAND_MAX)*2000000.0) ); - q.enqueue( new std::string( strbase ) ); - printf("[%d] write: %s\n", id, strbase ); - } - } - -private: - Bu::ItoQueue &q; - const char *strbase; - int id; -}; - -int main() -{ - Writer *wr[5]; - Reader *rd[5]; - const char bob[][7]={ - {"Test 1"}, - {"Test 2"}, - {"Test 3"}, - {"Test 4"}, - {"Test 5"} - }; - - Bu::ItoQueue q; - - for( int j = 0; j < 5; j++ ) - { - wr[j] = new Writer( q, j, bob[j] ); - rd[j] = new Reader( q, j ); - } - - for( int j = 0; j < 5; j++ ) - { - rd[j]->start(); - } - - for( int j = 0; j < 5; j++ ) - { - wr[j]->start(); - } - - for( int j = 0; j < 5; j++ ) - { - rd[j]->join(); - } - - for( int j = 0; j < 5; j++ ) - { - delete wr[j]; - delete rd[j]; - } - - return 0; -} - -- cgit v1.2.3