00001 /*========================================================================= 00002 00003 Program: Visualization Toolkit 00004 Module: $RCSfile: vtkAsynchronousBuffer.h,v $ 00005 Language: C++ 00006 00007 00008 Copyright (c) 1993-2001 Ken Martin, Will Schroeder, Bill Lorensen 00009 All rights reserved. 00010 00011 Redistribution and use in source and binary forms, with or without 00012 modification, are permitted provided that the following conditions are met: 00013 00014 * Redistributions of source code must retain the above copyright notice, 00015 this list of conditions and the following disclaimer. 00016 00017 * Redistributions in binary form must reproduce the above copyright notice, 00018 this list of conditions and the following disclaimer in the documentation 00019 and/or other materials provided with the distribution. 00020 00021 * Neither name of Ken Martin, Will Schroeder, or Bill Lorensen nor the names 00022 of any contributors may be used to endorse or promote products derived 00023 from this software without specific prior written permission. 00024 00025 * Modified source versions must be plainly marked as such, and must not be 00026 misrepresented as being the original software. 00027 00028 THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS ``AS IS'' 00029 AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 00030 IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 00031 ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHORS OR CONTRIBUTORS BE LIABLE FOR 00032 ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 00033 DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR 00034 SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER 00035 CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, 00036 OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE 00037 OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 00038 00039 =========================================================================*/ 00061 #ifndef __vtkAsynchronousBuffer_h 00062 #define __vtkAsynchronousBuffer_h 00063 00064 #include "vtkDataSetToDataSetFilter.h" 00065 #include "vtkMultiThreader.h" 00066 class vtkPortController; 00067 00068 00069 00070 class VTK_EXPORT vtkAsynchronousBuffer : public vtkDataSetToDataSetFilter 00071 { 00072 public: 00073 vtkTypeMacro(vtkAsynchronousBuffer,vtkDataSetToDataSetFilter); 00074 void PrintSelf(ostream& os, vtkIndent indent); 00075 static vtkAsynchronousBuffer *New(); 00076 00083 vtkSetMacro(Blocking, int); 00084 vtkGetMacro(Blocking, int); 00085 vtkBooleanMacro(Blocking, int); 00086 00088 void InternalUpdate(vtkDataObject *output); 00089 00091 void BlockingUpdate(); 00092 void NonblockingUpdate(); 00093 void PromoteData(); 00094 int TestForFinished(); 00095 void WaitForFinished(); 00096 00101 void UpdateInformation(); 00102 00105 vtkGetMacro(Finished, unsigned char); 00106 00107 // This ivar is public so thread function. can have access. 00108 // I do not think we need a lock on this variable. 00109 unsigned char Finished; 00110 unsigned char OutputConsumed; 00111 00112 protected: 00113 vtkAsynchronousBuffer(); 00114 ~vtkAsynchronousBuffer(); 00115 vtkAsynchronousBuffer(const vtkAsynchronousBuffer&) {}; 00116 void operator=(const vtkAsynchronousBuffer&) {}; 00117 00118 int Blocking; 00119 vtkMultiThreader *Threader; 00120 int ThreadId; 00121 00122 void BlockingUpdateInformation(); 00123 void NonblockingUpdateInformation(); 00124 void Execute(); 00125 }; 00126 00127 #endif 00128 00129