⭐ 欢迎来到虫虫下载站! | 📦 资源下载 📁 资源专辑 ℹ️ 关于我们
⭐ 虫虫下载站

📄 sync_8h-source.html

📁 最新版本!fastdb是高效的内存数据库系统
💻 HTML
字号:
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.0 Transitional//EN">
<html><head><meta http-equiv="Content-Type" content="text/html;charset=iso-8859-1">
<title>sync.h Source File</title>
<link href="doxygen.css" rel="stylesheet" type="text/css">
</head><body>
<!-- Generated by Doxygen 1.2.18 -->
<center>
<a class="qindex" href="index.html">Main Page</a> &nbsp; <a class="qindex" href="hierarchy.html">Class Hierarchy</a> &nbsp; <a class="qindex" href="annotated.html">Compound List</a> &nbsp; <a class="qindex" href="files.html">File List</a> &nbsp; <a class="qindex" href="functions.html">Compound Members</a> &nbsp; </center>
<hr><h1>sync.h</h1><div class="fragment"><pre>00001 <span class="comment">//-&lt; SYNC.H &gt;--------------------------------------------------------*--------*</span>
00002 <span class="comment">// FastDB                    Version 1.0         (c) 1999  GARRET    *     ?  *</span>
00003 <span class="comment">// (Main Memory Database Management System)                          *   /\|  *</span>
00004 <span class="comment">//                                                                   *  /  \  *</span>
00005 <span class="comment">//                          Created:     20-Nov-98    K.A. Knizhnik  * / [] \ *</span>
00006 <span class="comment">//                          Last update: 20-Dec-98    K.A. Knizhnik  * GARRET *</span>
00007 <span class="comment">//-------------------------------------------------------------------*--------*</span>
00008 <span class="comment">// Intertask synchonization primitives</span>
00009 <span class="comment">//-------------------------------------------------------------------*--------*</span>
00010 
00011 <span class="preprocessor">#ifndef __SYNC_H__</span>
00012 <span class="preprocessor"></span><span class="preprocessor">#define __SYNC_H__</span>
00013 <span class="preprocessor"></span>
00014 <span class="preprocessor">#ifdef _WIN32</span>
00015 <span class="preprocessor"></span><span class="preprocessor">#include "sync_w32.h"</span>    
00016 <span class="preprocessor">#else // Unix</span>
00017 <span class="preprocessor"></span><span class="preprocessor">#include "sync_unix.h"</span>
00018 <span class="preprocessor">#endif</span>
00019 <span class="preprocessor"></span>
00020 BEGIN_FASTDB_NAMESPACE
00021 
00022 <span class="keyword">class </span>FASTDB_DLL_ENTRY dbSystem { 
00023   <span class="keyword">public</span>:
00024     <span class="keyword">static</span> <span class="keywordtype">unsigned</span> getCurrentTimeMsec();
00025 };
00026 
00027 <span class="comment">// Common decls for all platforms</span>
00028 <span class="keyword">class </span>FASTDB_DLL_ENTRY dbCriticalSection { 
00029   <span class="keyword">private</span>:
00030     dbMutex&amp; mutex;
00031   <span class="keyword">public</span>:
00032     dbCriticalSection(dbMutex&amp; guard) : mutex(guard) {
00033         mutex.lock();
00034     }
00035     ~dbCriticalSection() { 
00036         mutex.unlock();
00037     }
00038 };
00039         
00040 <span class="preprocessor">#define SMALL_BUF_SIZE 512</span>
00041 <span class="preprocessor"></span>
00042 <span class="keyword">class </span>FASTDB_DLL_ENTRY dbSmallBuffer { 
00043   <span class="keyword">protected</span>:
00044     <span class="keywordtype">char</span>   smallBuf[SMALL_BUF_SIZE];
00045     <span class="keywordtype">char</span>*  buf;
00046     size_t used;
00047 
00048   <span class="keyword">public</span>:
00049     dbSmallBuffer(size_t size) { 
00050         <span class="keywordflow">if</span> (size &gt; SMALL_BUF_SIZE) { 
00051             buf = <span class="keyword">new</span> <span class="keywordtype">char</span>[size];
00052         } <span class="keywordflow">else</span> { 
00053             buf = smallBuf;
00054         }
00055         used = size;
00056     }
00057 
00058     dbSmallBuffer() { 
00059         used = 0;
00060         buf = smallBuf;
00061     }
00062 
00063     <span class="keywordtype">void</span> put(size_t size) { 
00064         <span class="keywordflow">if</span> (size &gt; SMALL_BUF_SIZE &amp;&amp; size &gt; used) { 
00065             <span class="keywordflow">if</span> (buf != smallBuf) { 
00066                 <span class="keyword">delete</span>[] buf;
00067             }
00068             buf = <span class="keyword">new</span> <span class="keywordtype">char</span>[size];
00069             used = size;
00070         }
00071     }
00072 
00073     operator char*() { <span class="keywordflow">return</span> buf; }
00074     <span class="keywordtype">char</span>* base() { <span class="keywordflow">return</span> buf; }
00075 
00076     ~dbSmallBuffer() { 
00077         <span class="keywordflow">if</span> (buf != smallBuf) { 
00078             <span class="keyword">delete</span>[] buf;
00079         }
00080     }
00081 };
00082 
00083 <span class="keyword">class </span>dbThreadPool;
00084 
00085 <span class="keyword">class </span>FASTDB_DLL_ENTRY dbPooledThread { 
00086   <span class="keyword">private</span>:
00087     <span class="keyword">friend</span> <span class="keyword">class </span>dbThreadPool;
00088 
00089     dbThread                thread;
00090     dbThreadPool*           pool;
00091     dbPooledThread*         next;
00092     dbThread::thread_proc_t f;
00093     <span class="keywordtype">void</span>*                   arg;
00094     <span class="keywordtype">bool</span>                    running;
00095     dbLocalSemaphore        startSem;
00096     dbLocalSemaphore        readySem;
00097     
00098     <span class="keyword">static</span> <span class="keywordtype">void</span> thread_proc  pooledThreadFunc(<span class="keywordtype">void</span>* arg);
00099 
00100     <span class="keywordtype">void</span> run();
00101     <span class="keywordtype">void</span> stop();
00102 
00103     dbPooledThread(dbThreadPool* threadPool); 
00104     ~dbPooledThread(); 
00105 };
00106 
00107 <span class="keyword">class </span>FASTDB_DLL_ENTRY dbThreadPool { 
00108     <span class="keyword">friend</span> <span class="keyword">class </span>dbPooledThread;
00109     dbPooledThread* freeThreads;
00110     dbMutex         mutex;
00111 
00112   <span class="keyword">public</span>:
00113     dbPooledThread* create(dbThread::thread_proc_t f, <span class="keywordtype">void</span>* arg);
00114     <span class="keywordtype">void</span> join(dbPooledThread* thr);
00115     dbThreadPool();
00116     ~dbThreadPool();
00117 };    
00118 
00119 END_FASTDB_NAMESPACE
00120     
00121 <span class="preprocessor">#endif // __SYNC_H__</span>
00122 <span class="preprocessor"></span>
00123 
</pre></div><hr><address style="align: right;"><small>Generated on Thu Feb 14 12:42:30 2008 for FastDB by
<a href="http://www.doxygen.org/index.html">
<img src="doxygen.png" alt="doxygen" align="middle" border=0 
width=110 height=53></a>1.2.18 </small></address>
</body>
</html>

⌨️ 快捷键说明

复制代码 Ctrl + C
搜索代码 Ctrl + F
全屏模式 F11
切换主题 Ctrl + Shift + D
显示快捷键 ?
增大字号 Ctrl + =
减小字号 Ctrl + -