📄 sync_8h-source.html
字号:
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"><html><head><meta http-equiv="Content-Type" content="text/html;charset=iso-8859-1"><title>FastDB: sync.h Source File</title><link href="doxygen.css" rel="stylesheet" type="text/css"></head><body><!-- Generated by Doxygen 1.3.5 --><div class="qindex"><a class="qindex" href="index.html">Main Page</a> | <a class="qindex" href="hierarchy.html">Class Hierarchy</a> | <a class="qindex" href="annotated.html">Class List</a> | <a class="qindex" href="files.html">File List</a> | <a class="qindex" href="functions.html">Class Members</a></div><h1>sync.h</h1><div class="fragment"><pre>00001 <span class="comment">//-< SYNC.H >--------------------------------------------------------*--------*</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="keyword">class </span>FASTDB_DLL_ENTRY dbSystem { 00015 <span class="keyword">public</span>:00016 <span class="keyword">static</span> <span class="keywordtype">unsigned</span> getCurrentTimeMsec();00017 };00018 00019 <span class="preprocessor">#ifdef _WIN32</span>00020 <span class="preprocessor"></span><span class="preprocessor">#include "sync_w32.h"</span> 00021 <span class="preprocessor">#else // Unix</span>00022 <span class="preprocessor"></span><span class="preprocessor">#include "sync_unix.h"</span>00023 <span class="preprocessor">#endif</span>00024 <span class="preprocessor"></span>00025 <span class="comment">// Common decls for all platforms</span>00026 <span class="keyword">class </span>FASTDB_DLL_ENTRY dbCriticalSection { 00027 <span class="keyword">private</span>:00028 dbMutex& mutex;00029 <span class="keyword">public</span>:00030 dbCriticalSection(dbMutex& guard) : mutex(guard) {00031 mutex.lock();00032 }00033 ~dbCriticalSection() { 00034 mutex.unlock();00035 }00036 };00037 00038 <span class="preprocessor">#define SMALL_BUF_SIZE 512</span>00039 <span class="preprocessor"></span>00040 <span class="keyword">class </span>FASTDB_DLL_ENTRY dbSmallBuffer { 00041 <span class="keyword">protected</span>:00042 <span class="keywordtype">char</span> smallBuf[SMALL_BUF_SIZE];00043 <span class="keywordtype">char</span>* buf;00044 size_t used;00045 00046 <span class="keyword">public</span>:00047 dbSmallBuffer(size_t size) { 00048 <span class="keywordflow">if</span> (size > SMALL_BUF_SIZE) { 00049 buf = <span class="keyword">new</span> <span class="keywordtype">char</span>[size];00050 } <span class="keywordflow">else</span> { 00051 buf = smallBuf;00052 }00053 used = size;00054 }00055 00056 dbSmallBuffer() { 00057 used = 0;00058 buf = smallBuf;00059 }00060 00061 <span class="keywordtype">void</span> put(size_t size) { 00062 <span class="keywordflow">if</span> (size > SMALL_BUF_SIZE && size > used) { 00063 <span class="keywordflow">if</span> (buf != smallBuf) { 00064 <span class="keyword">delete</span>[] buf;00065 }00066 buf = <span class="keyword">new</span> <span class="keywordtype">char</span>[size];00067 used = size;00068 }00069 }00070 00071 operator char*() { <span class="keywordflow">return</span> buf; }00072 <span class="keywordtype">char</span>* base() { <span class="keywordflow">return</span> buf; }00073 00074 ~dbSmallBuffer() { 00075 <span class="keywordflow">if</span> (buf != smallBuf) { 00076 <span class="keyword">delete</span>[] buf;00077 }00078 }00079 };00080 00081 00082 <span class="keyword">class </span>FASTDB_DLL_ENTRY dbPooledThread { 00083 <span class="keyword">private</span>:00084 <span class="keyword">friend</span> <span class="keyword">class </span>dbThreadPool;00085 00086 dbThread thread;00087 dbThreadPool* pool;00088 dbPooledThread* next;00089 dbThread::thread_proc_t f;00090 <span class="keywordtype">void</span>* arg;00091 <span class="keywordtype">bool</span> running;00092 dbLocalSemaphore startSem;00093 dbLocalSemaphore readySem;00094 00095 <span class="keyword">static</span> <span class="keywordtype">void</span> thread_proc pooledThreadFunc(<span class="keywordtype">void</span>* arg);00096 00097 <span class="keywordtype">void</span> run();00098 <span class="keywordtype">void</span> stop();00099 00100 dbPooledThread(dbThreadPool* threadPool); 00101 ~dbPooledThread(); 00102 };00103 00104 <span class="keyword">class </span>FASTDB_DLL_ENTRY dbThreadPool { 00105 <span class="keyword">friend</span> <span class="keyword">class </span>dbPooledThread;00106 dbPooledThread* freeThreads;00107 dbMutex mutex;00108 00109 <span class="keyword">public</span>:00110 dbPooledThread* create(dbThread::thread_proc_t f, <span class="keywordtype">void</span>* arg);00111 <span class="keywordtype">void</span> join(dbPooledThread* thr);00112 dbThreadPool();00113 ~dbThreadPool();00114 }; 00115 00116 <span class="preprocessor">#endif // __SYNC_H__</span>00117 <span class="preprocessor"></span>00118 </pre></div><hr size="1"><address style="align: right;"><small>Generated on Thu Feb 12 13:04:48 2004 for FastDB by<a href="http://www.doxygen.org/index.html"><img src="doxygen.png" alt="doxygen" align="middle" border=0 > </a>1.3.5 </small></address></body></html>⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -