如何设定每个帐号同一时间内允许的win7 连接数数?
点击联系发帖人
时间：2011-05-09 01:26
http://blog.csdn.net/ta8210/article/details/1582162
如何实现事务处理
&管理连接池
结合代码说明
启动服务StartService
停止服务StopService
申请&GetConnectionFormPool
释放DisposeConnection
如何更新属性
如何确定连接是否失效
使用线程管理连接池
threadCreate
threadCheck
步骤.在着一步骤中我们经常是,打开数据库连接操作数据库,最后关闭数据库.
,网上有很多的连接池例子,但是多数都是简单的例子,或者介绍比较复杂的连接池原理,没有一个比较完整介绍和实现连接池的例子.这里就介绍你如何自己制作一个连接池.
&连接池关键问题分析
）；如果没有就抛出一个异常给用户，List中连接是否可以被分配由一个线程来专门管理捎后我会介绍这个线程的具体实现。
在分配、释放策略对于有效复用连接非常重要，我们采用的方法也是采用了一个很有名的设计模式：Reference Counting（引用记数）。该模式在复用资源方面用的非常广泛，我们把该方法运用到对于连接的分配释放上。每一个数据库连接，保留一个引用记数，用来记录该连接的使用者的个数。具体的实现上，我们对Connection类进行进一步包装来实现引用记数。被包装的Connection类我们提供２个方法来实现引用记数的操作，一个是Repeat（被分配出去）Remove（被释放回来）；然后利用RepeatNow属性来确定当前被引用多少，具体是哪个用户引用了该连接将在连接池中登记；最后提供IsRepeat属性来确定该连接是否可以使用引用记数技术。一旦一个连接被分配出去，那么就会对该连接的申请者进行登记，并且增加引用记数，当被释放回来时候就删除他已经登记的信息，同时减少一次引用记数。
这样做有一个很大的好处，使得我们可以高效的使用连接，因为一旦所有连接都被分配出去，我们就可以根据相应的策略从使用池中挑选出一个已经正在使用的连接用来复用，而不是随意拿出一个连接去复用。策略可以根据需要去选择，我们有４策略可是使用：
１.ConnLevel_ReadOnly 独占方式
使用空闲的实际连接分配连接资源，并且在该资源释放回之前，该资源在连接池中将不能将其引用分配给其他申请者。如果连接池中所有实际连接资源都已经分配出去，那么即使连接池可以在分配引用资源在该模式下连接迟将不会分配连接资源，连接池会产生一个异常，标志连接池资源耗尽。
例：假如一个实际连接可以被分配5次，那么使用该模式申请连接的话您将损失4个可分配的连接，只将得到一个连接资源。 直至该资源被释放回连接池，连接池才继续分配它剩余的4次机会。
当你在使用连接时可能应用到事务时，可以使用该模式的连接，以确定在事务进行期间您可以对该连接具有独享权限，以避免各个数据库操作访问的干扰。
２.ConnLevel_High 优先级-高
使用空闲的实际连接分配连接资源，并且在该资源释放回之前，该资源在连接池中将可能将其引用分配给其他申请者。*注意：此级别不保证在分配该资源后，仍然保持独立占有连接资源，若想独立占有资源请使用ReadOnely， 因为当连接池达到某一时机时该资源将被重复分配（引用记数）然而这个时机是不可预测的。如果您申请的连接会用于事务处理您可以使用ConnLevel_ReadOnly级别。
３.ConnLevel_None 优先级-中
适当应用引用记数技术分配连接资源。
在该模式下，连接池内部会按照实际连接已经使用次数排序(多-&少)，然后在结果中选取 1/3 位置的连接资源返回。与优先级-高相同该模式也不具备保持独立占有连接资源的特性。如果您申请的连接会用于事务处理您可以使用ConnLevel_ReadOnly级别。
４.ConnLevel_Bottom 优先级-底
尽可能使用引用记数技术分配连接。在该模式下，连接池内部会按照实际连接已经使用次数排序(多-&少)，然后在结果中选取被使用最多的返回。该模式适合处理较为不重要的连接资源请求。与优先级-高相同该模式也不具备保持独立占有连接资源的特性。如果您申请的连接会用于事务处理您可以使用ConnLevel_ReadOnly级别。
以上4条策略选自datebasepool_SDK（datebasepool是本文所开发的最终产物）
如何实现事务处理
& 前面谈到的都是关于使用数据库连接进行普通的数据库访问。对于事务处理，情况就变得比较复杂。因为事务本身要求原子性的保证，此时就要求对于数据库的操作符合&All-All-Nothing&原则，即要么全部完成，要么什么都不做。如果简单的采用上述的连接复用的策略，就会发生问题，因为没有办法控制属于同一个事务的多个数据库操作方法的动作，可能这些数据库操作是在多个连接上进行的，并且这些连接可能被其他非事务方法复用。
Connection本身具有提供了对于事务的支持，具体实现方法请参看Connection的msdn，显式的调用commit或者rollback方法来实现。但是要安全、高效的进行Connection进行复用，就必须提供相应的事务支持机制。我们采用的方法是：用户以ConnLevel_ReadOnly模式申请一个连接之后该连接就由该申请者独自享有该连接，具体事务操作由用户自行设计编写，连接池只提供用户独自占有。
&管理连接池
在上文中我们说过这个连接池内部连接管理使用的是独立的线程来工作（threadCreate和threadCheck）threadCreate线程负责创建连接&，threadCheck线程负责检查每个连接是否达到自己的寿命，标志连接寿命的条件是被引用的次数超过它最大被引用次数，或者达到最大生存时间。这些参数都由ConnStruct类管理，ConnStruct类是包装连接的类，下面定义的就是连接池使用到的属性变量(C#代码)
&&&&&&&&//属性
&&&&&&&&private&int&_realFormP//连接池中存在的实际连接数(包含失效的连接)
&&&&&&&&private&int&_potentRealFormP//连接池中存在的实际连接数(有效的实际连接)
&&&&&&&&private&int&_spareRealFormP//空闲的实际连接
&&&&&&&&private&int&_useRealFormP//已分配的实际连接
&&&&&&&&private&int&_readOnlyFormP//连接池已经分配多少只读连接
&&&&&&&&private&int&_useFormP//已经分配出去的连接数
&&&&&&&&private&int&_spareFormP//目前可以提供的连接数
&&&&&&&&private&int&_maxC//最大连接数，最大可以创建的连接数目
&&&&&&&&private&int&_minC//最小连接数
&&&&&&&&private&int&_seepC//每次创建连接的连接数
&&&&&&&&private&int&_keepRealC//保留的实际空闲连接，以攻可能出现的ReadOnly使用，当空闲连接不足该数值时，连接池将创建seepConnection个连接
&&&&&&&&private&int&_exist&=&<span style="color:#;//每个连接生存期限&20分钟
&&&&&&&&private&int&_maxRepeatDegree&=&<span style="color:#;//可以被重复使用次数（引用记数），当连接被重复分配该值所表示的次数时，该连接将不能被分配出去
&&&&&&&&//当连接池的连接被分配尽时，连接池会在已经分配出去的连接中，重复分配连接（引用记数）。来缓解连接池压力
&&&&&&&&private&DateTime&_startT//服务启动时间
&&&&&&&&private&string&_connString&=&null;//连接字符串
&&&&&&&&private&ConnTypeEnum&_connT//连接池连接类型
&&&&&&&&private&PoolState&_//连接池状态
&&&&&&&&//内部对象
&&&&&&&&private&ArrayList&al_All&=&new&ArrayList();//实际连接
&&&&&&&&private&Hashtable&hs_UseConn&=&new&Hashtable();//正在使用的连接
&&&&&&&&private&System.Timers.Timer&//监视器记时器
&&&&&&&&private&Thread&threadC//创建线程
&&&&&&&&private&bool&isThreadCheckRun&=&false;
&&&&//属性
&&&&private&int&_RealFormP&//连接池中存在的实际连接数(包含失效的连接)
&&&&private&int&_PotentRealFormP&//连接池中存在的实际连接数(有效的实际连接)
&&&&private&int&_SpareRealFormP&//空闲的实际连接
&&&&private&int&_UseRealFormP&//已分配的实际连接
&&&&private&int&_ReadOnlyFormP&//连接池已经分配多少只读连接
&&&&private&int&_UseFormP&//已经分配出去的连接数
&&&&private&int&_SpareFormP&//目前可以提供的连接数
&&&&private&int&_MaxC&//最大连接数，最大可以创建的连接数目
&&&&private&int&_MinC&//最小连接数
&&&&private&int&_SeepC&//每次创建连接的连接数
&&&&private&int&_KeepRealC&//保留的实际空闲连接，以攻可能出现的ReadOnly使用，当空闲连接不足该数值时，连接池将创建seepConnection个连接
&&&&private&int&_Exist&=&<span style="color:#;&//每个连接生存期限&20分钟
&&&&private&String&_userID=&&;
&&&&private&String&_password=&&;
&&&&//可以被重复使用次数（引用记数），当连接被重复分配该值所表示的次数时，该连接将不能被分配出去
&&&&//当连接池的连接被分配尽时，连接池会在已经分配出去的连接中，重复分配连接（引用记数）。来缓解连接池压力
&&&&private&int&_MaxRepeatDegree&=&<span style="color:#;
&&&&private&Date&_StartT&//服务启动时间
&&&&private&String&_ConnString&=&null;&//连接字符串
&&&&private&String&_DriveString&=&null;&//驱动字符串
&&&&private&int&_PoolS&//连接池状态
&&&&//内部对象
&&&&private&ArrayList&al_All&=&new&ArrayList();&//实际连接
&&&&private&Hashtable&hs_UseConn&=&new&Hashtable();&//正在使用的连接
&&&&private&CreateThreadProcess&threadC
&&&&private&CheckThreadProcess&threadC
当用户调用连接池的StartService方法时，在StartService方法中会通知threadCreate线程创建静态连接，然后将这些静态连接加入到List，同时启动threadCheck线程，threadCheck线程负责检测List中的最小空闲连接是否少于连接池配置的最少空闲连接数，当条件为真时threadCheck线程会负责再次唤醒threadCreate线程同时给threadCreate线程传递这次要创建的连接个数。
对于threadCreate线程有２种工作模式，模式０为初始化创建模式，该模式会创建连接迟池配置的最小连接数目；模式１即每隔一定时间就对连接池进行检测，如果发现连接数量小于最小连接数，则补充相应数量的新连接时的工作模式。
申请连接，当用户申请连接时必须指定一个发起者和一个申请优先级别，优先级由ConnLevel_*系列指定。一旦用户从连接池中申请到一个连接时就将申请到的连接引用和申请者，同时加入到HashTable来注册到连接池。
释放连接，将注册的用户删除。&&
&下面是代码说明
共有Java和C#２个版本，２版本可能捎有不同因为各个语言有自己的特点
Java版本的构造方法
&&&&public&ConnectionPool()&...{
&&&&&&&&InitConnectionPool(&&,&&&,&<span style="color:#0,&<span style="color:#,&<span style="color:#,&<span style="color:#);
&&&&public&ConnectionPool(String&connectionString,&String&driveString)&...{
&&&&&&&&InitConnectionPool(connectionString,&driveString,&<span style="color:#0,&<span style="color:#,&<span style="color:#,&<span style="color:#);
&&&&public&ConnectionPool(String&connectionString,&String&driveString,&int&maxConnection,&int&minConnection)&...{
&&&&&&&&InitConnectionPool(connectionString,&driveString,&maxConnection,&minConnection,&<span style="color:#,&<span style="color:#);
&&&&public&ConnectionPool(String&connectionString,&String&driveString,&int&maxConnection,&int&minConnection,&int&seepConnection,&int&keepRealConnection)&...{
&&&&&&&&InitConnectionPool(connectionString,&driveString,&maxConnection,&minConnection,&seepConnection,&keepRealConnection);
C#版本的构造方法
&&&&&&&&public&ConnectionPool(string&connectionString)
&&&&&&&&...{&InitConnectionPool(connectionString,&ConnTypeEnum.Odbc,&<span style="color:#0,&<span style="color:#,&<span style="color:#,&<span style="color:#,&<span style="color:#);&}
&&&&&&&&public&ConnectionPool(string&connectionString,&ConnTypeEnum&cte)
&&&&&&&&...{&InitConnectionPool(connectionString,&cte,&<span style="color:#0,&<span style="color:#,&<span style="color:#,&<span style="color:#,&<span style="color:#);&}
&&&&&&&&public&ConnectionPool(string&connectionString,&ConnTypeEnum&cte,&int&maxConnection,&int&minConnection)
&&&&&&&&...{&InitConnectionPool(connectionString,&cte,&maxConnection,&minConnection,&<span style="color:#,&<span style="color:#,&<span style="color:#);&}
&&&&&&&&public&ConnectionPool(string&connectionString,&ConnTypeEnum&cte,&int&maxConnection,&int&minConnection,&int&seepConnection,&int&keepConnection)
&&&&&&&&...{&InitConnectionPool(connectionString,&cte,&maxConnection,&minConnection,&seepConnection,&keepConnection,&<span style="color:#);&}
&&&&&&&&public&ConnectionPool(string&connectionString,&ConnTypeEnum&cte,&int&maxConnection,&int&minConnection,&int&seepConnection,&int&keepConnection,&int&keepRealConnection)
&&&&&&&&...{&InitConnectionPool(connectionString,&cte,&maxConnection,&minConnection,&seepConnection,&keepConnection,&keepRealConnection);&}
上面２个版本的构造方法都调用InitConnectionPool方法，下面是InitConnectionPool方法实现(C#)
&&&&&&&&/**////&&summary&
&&&&&&&&///&初始化函数
&&&&///&&/summary&
&&&&&&&&protected&void&InitConnectionPool(string&connectionString,&ConnTypeEnum&cte,&int&maxConnection,&int&minConnection,&int&seepConnection,&int&keepConnection,&int&keepRealConnection)
&&&&&&&&...{
&&&&&&&&&&&&if&(cte&==&ConnTypeEnum.None)
&&&&&&&&&&&&&&&&throw&new&ConnTypeExecption();//参数不能是None
&&&&&&&&&&&&_ps&=&PoolState.UnI
&&&&&&&&&&&&this._connString&=&connectionS
&&&&&&&&&&&&this._connType&=&
&&&&&&&&&&&&this._minConnection&=&minC
&&&&&&&&&&&&this._seepConnection&=&seepC
&&&&&&&&&&&&this._keepRealConnection&=&keepRealC
&&&&&&&&&&&&this._maxConnection&=&maxC
&&&&&&&&&&&&this.time&=&new&System.Timers.Timer(<span style="color:#0);
&&&&&&&&&&&&this.time.Stop();
&&&&&&&&&&&&this.time.Elapsed&+=&new&System.Timers.ElapsedEventHandler(time_Elapsed);
&&&&&&&&&&&&this.threadCreate&=&new&Thread(new&ThreadStart(createThreadProcess));
& 在InitConnectionPool方法中我们定义了连接池要连接的数据库类型ConnTypeEnum&cte，和连接字符串stringconnectionString等类型，在方法最后注册了Timer类的Elapsed&事件，在C#版中Timer类就充当threadCheck线程，而Elapsed事件就是线程threadCheck的执行方法体。
由于刚刚初始化连接池对象故threadCheck线程不需要运行所以在InitConnectionPool方法中将Timer关闭。下面是java实现：&&&
&&&&private&void&InitConnectionPool(String&connectionString,&String&driveString,&int&maxConnection,&int&minConnection,&int&seepConnection,&int&keepRealConnection)&...{
&&&&&&&&this._PoolState&=&PoolState_UnI
&&&&&&&&this._ConnString&=&connectionS
&&&&&&&&this._DriveString&=&driveS
&&&&&&&&this._MinConnection&=&minC
&&&&&&&&this._SeepConnection&=&seepC
&&&&&&&&this._KeepRealConnection&=&keepRealC
&&&&&&&&this._MaxConnection&=&maxC
&&&&&&&&this.threadCheck&=&new&CheckThreadProcess();
&&&&&&&&this.threadCheck.setDaemon(true);
&&&&&&&&this.threadCreate&=&new&CreateThreadProcess();
&&&&&&&&this.threadCreate.setDaemon(true);
&&&&&&&&this.threadCheck.start();
&&&&while(threadCheck.getState()!=Thread.State.WAITING)...{}
由于Java中的Timer类需要AWT 的GUI线程组建支持，总不能在我们的连接池中开辟一个Form出来把，因此在Java版本中使用线程来实现Timer，在Java版本中threadCheck一开始就被启动，然后又等待threadCheck线程自己被阻塞又是为什么呢，这样做是为了实现C#版本中stop方法.（由于个人原因这个连接池最初是由C#.Net2.0开发而成的故而在Java中可能存在许多设计不合理）。
由上面代码可以看出一旦连接池被创建出来以后就已经运行了一个threadCheck线程(对于Java版)，而这个线程将立刻进入WAITING等待状态。
&启动服务StartService
&&&&&&&&/**////&&summary&
&&&&&&&&///&启动服务，线程安全
&&&&&&&&///&&/summary&
&&&&&&&&public&void&StartServices()
&&&&&&&&...{
&&&&&&&&&&&&lock&(this)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&createThreadMode&=&<span style="color:#;//工作模式0
&&&&&&&&&&&&&&&&createThreadProcessRun&=&true;
&&&&&&&&&&&&&&&&createThreadProcessTemp&=&_minC
&&&&&&&&&&&&&&&&if&(_ps&==&PoolState.UnInitialize)
&&&&&&&&&&&&&&&&&&&&threadCreate.Start();
&&&&&&&&&&&&&&&&else&if&(_ps&==&PoolState.Stop)
&&&&&&&&&&&&&&&&&&&&threadCreate.Interrupt();
&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&throw&new&PoolNotStopException();//服务已经运行或者未完全结束
&&&&&&&&&&&&&&&&time.Start();
&&&&&&&&&&&&}
createThreadMode&是设置threadCreate的工作模式为０创建模式，前面我们说过threadCreate有２种工作模式，如果忘记了就回头去看看把。
createThreadProcessTemp是threadCreate工作需要的参数变量threadCreate会在0或者1这两种工作模式下用到这个临时变量该变量作用就是告诉threadCreate要创建多少个连接，下面的一组if ....&else 是为了将threadCreate线程运行起来 _ps是表示当前连接池状态，下面是_ps的定义，在Java版本中PoolState只是一组public static final int故在这里不在将源码放出。
在StartServices最后我们启动了time也就是threadCheck线程。
&&&&//&连接池状态
&&&&public&enum&PoolState
&&&&&&&&UnInitialize,//&刚刚创建的对象，表示该对象未被调用过StartSeivice方法。
&&&&&&&&Initialize,//&初始化中，该状态下服务正在按照参数初始化连接池。
&&&&&&&&Run,//运行中
&&&&&&&&Stop//停止状态
PoolState定义
&&&/**&*//**
&&&&&*&启动连接池服务
&&&&&*&@throws&PoolNotStopException&服务已经运行或者未完全结束
&&&&public&void&StartServices()&throws&PoolNotStopException&...{
&&&&&&&&synchronized&(this)&...{
&&&&&&&&&&&&threadCreate.createThreadMode&=&<span style="color:#;&//工作模式0
&&&&&&&&&&&&threadCreate.createThreadProcessRun&=&true;
&&&&&&&&&&&&threadCreate.createThreadProcessTemp&=&_MinC
&&&&&&&&&&&&if&(_PoolState&==&PoolState_UnInitialize)
&&&&&&&&&&&&&&&&threadCreate.start();
&&&&&&&&&&&&else&if&(_PoolState&==&PoolState_Stop)
&&&&&&&&&&&&&&&&threadCreate.interrupt();
&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&throw&new&PoolNotStopException();&//服务已经运行或者未完全结束
&&&&&&&&&&&&threadCheck.StartTimer();
&&&&&&&&&&&&threadCheck.interrupt();//开始运行
&停止服务StopService
&&&&&&&&/**////&&summary&
&&&&&&&&///&停止服务，线程安全
&&&&&&&&///&&/summary&
&&&&&&&&public&void&StopServices()
&&&&&&&&...{&StopServices(false);&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&停止服务，线程安全
&&&&&&&&///&¶m&name=&needs&&是否必须退出；如果指定为false与StartServices()功能相同，如果指定为true。将未收回的连接资源关闭，这将是危险的。认为可能你的程序正在使用此资源。&/param&
&&&&&&&&///&&/summary&
&&&&&&&&public&void&StopServices(bool&needs)
&&&&&&&&...{
&&&&&&&&&&&&lock&(this)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&if&(_ps&==&PoolState.Run)
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&lock&(hs_UseConn)
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&if&(needs&==&true)//必须退出
&&&&&&&&&&&&&&&&&&&&&&&&&&&&hs_UseConn.Clear();
&&&&&&&&&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&&&&&&&&&if&(hs_UseConn.Count&!=&<span style="color:#)
&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&throw&new&ResCallBackException();//连接池资源未全部回收
&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&time.Stop();
&&&&&&&&&&&&&&&&&&&&while&(isThreadCheckRun)&...{&}//等待timer事件结束
&&&&&&&&&&&&&&&&&&&&createThreadProcessRun&=&false;
&&&&&&&&&&&&&&&&&&&&while&(threadCreate.ThreadState&!=&ThreadState.WaitSleepJoin)&...{&}//等待可能存在的创建线程结束
&&&&&&&&&&&&&&&&&&&&lock&(al_All)
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&for&(int&i&=&<span style="color:#;&i&&&al_All.C&i++)
&&&&&&&&&&&&&&&&&&&&&&&&&&&&((ConnStruct)al_All[i]).Dispose();
&&&&&&&&&&&&&&&&&&&&&&&&al_All.Clear();
&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&_ps&=&PoolState.S
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&throw&new&PoolNotRunException();//服务未启动
&&&&&&&&&&&&}
&&&&&&&&&&&&UpdateAttribute();//更新属性
在这里我们使用了2层锁第一层锁我们是为了保证同一时间只能有一个线程调用这个方法，而lock&(hs_UseConn)则是为了保护hs_UseConn的唯一访问hs_UseConn存放的就是申请连接时注册信息，needs是将未收回的连接资源也关闭，这将是危险的。认为可能你的程序正在使用此资源。
if&(hs_UseConn.Count&!=&<span style="color:#)
&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&throw&new&ResCallBackException();//连接池资源未全部回收。
这段代码是表示如果用户试图在连接没有全部释放回来时候将会引发异常，同时执行该方法的必要条件是连接池必须处在PoolState_Run状态。
time.Stop();是停止检测线程的运行,while&(isThreadCheckRun)&...{&}那为什么要使用这个空循环等待timer的结束呢？原因是Timer类的运行基理，在C#下Timer触发的事件是不同于ＶＢ的，在.Net里无论Timer事件处理过程的执行时间是否超过它触发时间间隔在Timer里总会在指定时间被调用，也就是说如果触发间隔却是100毫秒，然而我们的处理过程用了500毫秒来运行代码。这样的话下一个事件的触发将在我们这个事件还没有结束时又进行了，如此一来起不是灾难的！
对于接下来我们还要等待可能存在的threadCreate线程结束，不过在等待它结束时先给他发送一个暂停信号，这个信号由createThreadProcessRun&变量传递进去。也许有人回问为什么不使用join来阻止threadCreate的运行，原因是这样的，假如threadCreate打算创建minConnection个连接，然而恰恰在创建到minConnection - n 个时候我停止也连接池，如果在这里使用join的话我们将不确定下次恢复运行时候究竟要创建多少个连接，最好的解决办法就是叫线程自己找一个安全的地方把自己join。
在下面的代码就是把每一个连接分别销毁掉并且在连接池中将它删除掉。有人说，那你只是删除了你内部的引用，的确我们只删除了内部的引用，因为销毁只是形式的销毁在.net上我们不能控制内存去销毁一个对象，只能叫GC帮忙来清理它。在程序段的最后我们使用私有的UpdateAttribute方法来更新属性字段。
&下面是Java版本的代码
&&&&/**&*//**
&&&&&*&停止服务，线程安全
&&&&&*&@throws&ResCallBackException&资源未全部回首
&&&&&*&@throws&PoolNotRunException&服务没有运行
&&&&public&void&StopServices()&throws&ResCallBackException,&PoolNotRunException&...{
&&&&&&&&StopServices(false);
&&&&/**&*//**
&&&&&*&停止服务，线程安全
&&&&&*&@param&needs&boolean&是否必须退出；如果指定为false与StartServices()功能相同，如果指定为true。将未收回的连接资源关闭，这将是危险的。认为可能你的程序正在使用此资源。
&&&&&*&@throws&ResCallBackException&服务未启动
&&&&&*&@throws&PoolNotRunException&服务没有运行
&&&&public&void&StopServices(boolean&needs)&throws&PoolNotRunException,&ResCallBackException&...{
&&&&&&&&synchronized&(this)&...{
&&&&&&&&&&&&if&(_PoolState&==&PoolState_Run)&...{
&&&&&&&&&&&&&&&&synchronized&(hs_UseConn)&...{
&&&&&&&&&&&&&&&&&&&&if&(needs&==&true)&//必须退出
&&&&&&&&&&&&&&&&&&&&&&&&hs_UseConn.clear();
&&&&&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&if&(hs_UseConn.size()&!=&<span style="color:#)
&&&&&&&&&&&&&&&&&&&&&&&&throw&new&ResCallBackException();&//连接池资源未全部回收
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&threadCheck.StopTimer();
&&&&&&&&&&&&&&&&while&(threadCreate.getState()!=Thread.State.WAITING)&...{&}//等待threadCreate事件结束
&&&&&&&&&&&&&&&&threadCreate.createThreadProcessRun&=&false;
&&&&&&&&&&&&&&&&while&(threadCreate.getState()&!=&Thread.State.WAITING)&...{}&//等待可能存在的创建线程结束
&&&&&&&&&&&&&&&&synchronized&(al_All)&...{
&&&&&&&&&&&&&&&&&&&&for&(int&i&=&<span style="color:#;&i&&&al_All.size();&i++)
&&&&&&&&&&&&&&&&&&&&&&&&((ConnStruct)&al_All.get(i)).Dispose();
&&&&&&&&&&&&&&&&&&&&al_All.clear();
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&_PoolState&=&PoolState_S
&&&&&&&&&&&&}&else
&&&&&&&&&&&&&&&&throw&new&PoolNotRunException();&//服务未启动
&&&&&&&&UpdateAttribute();&//更新属性
申请&GetConnectionFormPool
&&&&&&&&/**////&&summary&
&&&&&&&&///&在连接池中申请一个连接，使用None级别，线程安全
&&&&&&&&///&&/summary&
&&&&&&&&///&¶m&name=&gui&&发起者&/param&
&&&&&&&&///&&returns&返回申请到的连接&/returns&
&&&&&&&&public&DbConnection&GetConnectionFormPool(object&key)
&&&&&&&&...{&return&GetConnectionFormPool(key,&ConnLevel.None);&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&在连接池中申请一个连接，线程安全
&&&&&&&&///&&/summary&
&&&&&&&&///&¶m&name=&key&&申请者&/param&
&&&&&&&&///&¶m&name=&cl&&申请的连接级别&/param&
&&&&&&&&///&&returns&返回申请到的连接&/returns&
&&&&&&&&public&DbConnection&GetConnectionFormPool(object&key,&ConnLevel&cl)
&&&&&&&&...{
&&&&&&&&&&&&lock&(this)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&if&(_ps&!=&PoolState.Run)
&&&&&&&&&&&&&&&&&&&&throw&new&StateException();//服务状态错误
&&&&&&&&&&&&&&&&if&(hs_UseConn.Count&==&MaxConnectionFormPool)
&&&&&&&&&&&&&&&&&&&&throw&new&PoolFullException();//连接池已经饱和，不能提供连接
&&&&&&&&&&&&&&&&if&(hs_UseConn.ContainsKey(key))
&&&&&&&&&&&&&&&&&&&&throw&new&KeyExecption();//一个key对象只能申请一个连接
&&&&&&&&&&&&&&&&if&(cl&==&ConnLevel.ReadOnly)
&&&&&&&&&&&&&&&&&&&&return&GetConnectionFormPool_ReadOnly(key);//ReadOnly级别
&&&&&&&&&&&&&&&&else&if&(cl&==&ConnLevel.High)
&&&&&&&&&&&&&&&&&&&&return&GetConnectionFormPool_High(key);//High级别
&&&&&&&&&&&&&&&&else&if&(cl&==&ConnLevel.None)
&&&&&&&&&&&&&&&&&&&&return&GetConnectionFormPool_None(key);//None级别
&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&return&GetConnectionFormPool_Bottom(key);//Bottom级别
&&&&&&&&&&&&}
& &在向连接池申请一个连接资源时我们必须指定一个申请者，同时可以指定一个级别参数最后会根据不同的级别调用不同的策略，这些策略是在上面介绍过的4钟策略，下面不做过多的介绍。
（Java版本不在放出原因代码与C#完全相同）
下面将逐一放出４种策略的完整代码不做过多解释，其功能以在前文介绍过
&&&&&&&&/**////&&summary&
&&&&&&&&///&申请一个连接资源，只读方式，线程安全
&&&&&&&&///&&/summary&
&&&&&&&&///&¶m&name=&key&&申请者&/param&
&&&&&&&&///&&returns&申请到的连接对象&/returns&
&&&&&&&&protected&DbConnection&GetConnectionFormPool_ReadOnly(object&key)
&&&&&&&&...{
&&&&&&&&&&&&ConnStruct&cs&=&null;
&&&&&&&&&&&&for&(int&i&=&<span style="color:#;&i&&&al_All.C&i++)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&cs&=&(ConnStruct)al_All[i];
&&&&&&&&&&&&&&&&if&(cs.Enable&==&false&||&cs.Allot&==&false&||&cs.UseDegree&==&_maxRepeatDegree&||&cs.IsUse&==&true)
&&&&&&&&&&&&&&&&&&&&continue;
&&&&&&&&&&&&&&&&return&GetConnectionFormPool_Return(key,&cs,&ConnLevel.ReadOnly);&//返回得到的连接
&&&&&&&&&&&&}
&&&&&&&&&&&&return&GetConnectionFormPool_Return(key,&null,&ConnLevel.ReadOnly);
&&&&&&&&/**////&&summary&
&&&&&&&&///&申请一个连接资源，优先级-高，线程安全
&&&&&&&&///&&/summary&
&&&&&&&&///&¶m&name=&key&&申请者&/param&
&&&&&&&&///&&returns&申请到的连接对象&/returns&
&&&&&&&&protected&DbConnection&GetConnectionFormPool_High(object&key)
&&&&&&&&...{
&&&&&&&&&&&&ConnStruct&cs&=&null;
&&&&&&&&&&&&ConnStruct&csTemp&=&null;
&&&&&&&&&&&&for&(int&i&=&<span style="color:#;&i&&&al_All.C&i++)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&csTemp&=&(ConnStruct)al_All[i];
&&&&&&&&&&&&&&&&if&(csTemp.Enable&==&false&||&csTemp.Allot&==&false&||&csTemp.UseDegree&==&_maxRepeatDegree)//不可以分配跳出本次循环。
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&csTemp&=&null;
&&&&&&&&&&&&&&&&&&&&continue;
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&if&(csTemp.UseDegree&==&<span style="color:#)//得到最合适的
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&cs&=&csT
&&&&&&&&&&&&&&&&&&&&break;
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&else//不是最合适的放置到最佳选择中
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&if&(cs&!=&null)
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&if&(csTemp.UseDegree&&&cs.UseDegree)
&&&&&&&&&&&&&&&&&&&&&&&&&&&&//与上一个最佳选择选出一个最佳的放置到cs中
&&&&&&&&&&&&&&&&&&&&&&&&&&&&cs&=&csT
&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&&&&&cs&=&csT
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&}
&&&&&&&&&&&&return&GetConnectionFormPool_Return(key,&cs,&ConnLevel.High);//返回最合适的连接
&&&&&&&&/**////&&summary&
&&&&&&&&///&申请一个连接资源，优先级-中，线程安全
&&&&&&&&///&&/summary&
&&&&&&&&///&¶m&name=&key&&申请者&/param&
&&&&&&&&///&&returns&申请到的连接对象&/returns&
&&&&&&&&protected&DbConnection&GetConnectionFormPool_None(object&key)
&&&&&&&&...{
&&&&&&&&&&&&ArrayList&al&=&new&ArrayList();
&&&&&&&&&&&&ConnStruct&cs&=&null;
&&&&&&&&&&&&for&(int&i&=&<span style="color:#;&i&&&al_All.C&i++)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&cs&=&(ConnStruct)al_All[i];
&&&&&&&&&&&&&&&&if&(cs.Enable&==&false&||&cs.Allot&==&false&||&cs.UseDegree&==&_maxRepeatDegree)//不可以分配跳出本次循环。
&&&&&&&&&&&&&&&&&&&&continue;
&&&&&&&&&&&&&&&&if&(cs.Allot&==&true)
&&&&&&&&&&&&&&&&&&&&al.Add(cs);
&&&&&&&&&&&&}
&&&&&&&&&&&&if&(al.Count&==&<span style="color:#)
&&&&&&&&&&&&&&&&return&GetConnectionFormPool_Return(key,&null,&ConnLevel.None);//发出异常
&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&return&GetConnectionFormPool_Return(key,&((ConnStruct)al[al.Count&/&<span style="color:#]),&ConnLevel.None);//返回连接
&&&&&&&&/**////&&summary&
&&&&&&&&///&申请一个连接资源，优先级-低，线程安全
&&&&&&&&///&&/summary&
&&&&&&&&///&¶m&name=&key&&申请者&/param&
&&&&&&&&///&&returns&申请到的连接对象&/returns&
&&&&&&&&protected&DbConnection&GetConnectionFormPool_Bottom(object&key)
&&&&&&&&...{
&&&&&&&&&&&&ConnStruct&cs&=&null;
&&&&&&&&&&&&ConnStruct&csTemp&=&null;
&&&&&&&&&&&&for&(int&i&=&<span style="color:#;&i&&&al_All.C&i++)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&csTemp&=&(ConnStruct)al_All[i];
&&&&&&&&&&&&&&&&if&(csTemp.Enable&==&false&||&csTemp.Allot&==&false&||&csTemp.UseDegree&==&_maxRepeatDegree)//不可以分配跳出本次循环。
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&csTemp&=&null;
&&&&&&&&&&&&&&&&&&&&continue;
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&else//不是最合适的放置到最佳选择中
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&if&(cs&!=&null)
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&if&(csTemp.UseDegree&&&cs.UseDegree)
&&&&&&&&&&&&&&&&&&&&&&&&&&&&//与上一个最佳选择选出一个最佳的放置到cs中
&&&&&&&&&&&&&&&&&&&&&&&&&&&&cs&=&csT
&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&&&&&cs&=&csT
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&}
&&&&&&&&&&&&return&GetConnectionFormPool_Return(key,&cs,&ConnLevel.Bottom);//返回最合适的连接
Java版本不在放出原因代码与C#完全相同
&&在上面代码中所有策略都调用GetConnectionFormPool_Return方法。具体是什么呢？让我们来看看
&&&&&&&&/**////&&summary&
&&&&&&&&///&返回DbConnection对象，同时做获得连接时的必要操作
&&&&&&&&///&&/summary&
&&&&&&&&///&¶m&name=&key&&key&/param&
&&&&&&&&///&¶m&name=&cs&&ConnStruct对象&/param&
&&&&&&&&///&¶m&name=&cl&&级别&/param&
&&&&&&&&///&¶m&name=&readOnly&&是否为只读属性&/param&
&&&&&&&&///&&returns&&/returns&
&&&&&&&&private&DbConnection&GetConnectionFormPool_Return(object&key,&ConnStruct&cs,&ConnLevel&cl)
&&&&&&&&...{
&&&&&&&&&&&&try
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&if&(cs&==&null)
&&&&&&&&&&&&&&&&&&&&throw&new&Exception();
&&&&&&&&&&&&&&&&cs.Repeat();
&&&&&&&&&&&&&&&&hs_UseConn.Add(key,&cs);
&&&&&&&&&&&&&&&&if&(cl&==&ConnLevel.ReadOnly)
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&cs.Allot&=&false;
&&&&&&&&&&&&&&&&&&&&cs.IsRepeat&=&false;
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&}
&&&&&&&&&&&&catch&(Exception&e)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&throw&new&OccasionExecption();//连接资源耗尽，或错误的访问时机。
&&&&&&&&&&&&}
&&&&&&&&&&&&finally
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&UpdateAttribute();//更新属性
&&&&&&&&&&&&}
&&&&&&&&&&&&return&cs.C
该方法就是返回DbConnection对象，同时将获得的连接引用记数+1，在程序的第一行进行了一下内部错误判断如果是一个空的cs则抛出一个异常，该异常由方法体内接收并且将异常统一包装为OccasionExecption类型异常。hs_UseConn.Add(key,&cs);是将被申请到的连接资源注册到连接池。同时也确定这个被申请走的连接是不是以只读方式申请的，如果是则将这个连接锁定。
cs.Allot&=&false;//设置该连接不能再次被分配
&cs.IsRepeat&=&false;//设置连接不能使用引用记数技术
(Java版本不在放出原因代码与C#完全相同)
&释放DisposeConnection
&&&&&&&&/**////&&summary&
&&&&&&&&///&释放申请的数据库连接对象，线程安全
&&&&&&&&///&¶m&name=&key&&key表示数据库连接申请者&/param&
&&&&&&&&///&&/summary&
&&&&&&&&public&void&DisposeConnection(object&key)
&&&&&&&&...{
&&&&&&&&&&&&lock&(hs_UseConn)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&ConnStruct&cs&=&null;
&&&&&&&&&&&&&&&&if&(_ps&==&PoolState.Run)
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&if&(!hs_UseConn.ContainsKey(key))
&&&&&&&&&&&&&&&&&&&&&&&&throw&new&NotKeyExecption();//无法释放，不存在的key
&&&&&&&&&&&&&&&&&&&&cs&=&(ConnStruct)hs_UseConn[key];
&&&&&&&&&&&&&&&&&&&&cs.IsRepeat&=&true;
&&&&&&&&&&&&&&&&&&&&if&(cs.Allot&==&false)
&&&&&&&&&&&&&&&&&&&&&&&&if&(cs.Enable&==&true)
&&&&&&&&&&&&&&&&&&&&&&&&&&&&cs.Allot&=&true;
&&&&&&&&&&&&&&&&&&&&cs.Remove();
&&&&&&&&&&&&&&&&&&&&hs_UseConn.Remove(key);
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&throw&new&PoolNotRunException();//服务未启动
&&&&&&&&&&&&}
&&&&&&&&&&&&UpdateAttribute();//更新属性
&在释放资源中可以说是上面申请资源的反方向操作其中不同点在于
if&(cs.Enable&==&true)
cs.Allot&=&true;
这段话的意思是如果连接对象已经失效则不更改会不会再次被分配的属性如果仍然有效则更改为会再次被分配，因为被包装后的Connection不会自己知道自己是否已经超过引用记数所要求的最大上限。
(Java版本不在放出原因代码与C#完全相同)
如何更新属性
&&&&&&&&/**////&&summary&
&&&&&&&&///&更新属性
&&&&&&&&///&&/summary&
&&&&&&&&private&void&UpdateAttribute()
&&&&&&&&...{
&&&&&&&&&&&&int&temp_readOnlyFormPool&=&<span style="color:#;//连接池已经分配多少只读连接
&&&&&&&&&&&&int&temp_potentRealFormPool&=&<span style="color:#;//连接池中存在的实际连接数(有效的实际连接)
&&&&&&&&&&&&int&temp_spareRealFormPool&=&<span style="color:#;//空闲的实际连接
&&&&&&&&&&&&int&temp_useRealFormPool&=&<span style="color:#;//已分配的实际连接
&&&&&&&&&&&&int&temp_spareFormPool&=&MaxConnectionFormP//目前可以提供的连接数
&&&&&&&&&&&&//---------------------------------
&&&&&&&&&&&&lock&(hs_UseConn)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&_useFormPool&=&hs_UseConn.C
&&&&&&&&&&&&}
&&&&&&&&&&&&//---------------------------------
&&&&&&&&&&&&ConnStruct&cs&=&null;
&&&&&&&&&&&&int&n&=&<span style="color:#;
&&&&&&&&&&&&lock&(al_All)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&_realFormPool&=&al_All.C
&&&&&&&&&&&&&&&&for&(int&i&=&<span style="color:#;&i&&&al_All.C&i++)
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&cs&=&(ConnStruct)al_All[i];
&&&&&&&&&&&&&&&&&&&&//只读
&&&&&&&&&&&&&&&&&&&&if&(cs.Allot&==&false&&&&cs.IsUse&==&true&&&&cs.IsRepeat&==&false)
&&&&&&&&&&&&&&&&&&&&&&&&temp_readOnlyFormPool++;
&&&&&&&&&&&&&&&&&&&&//有效的实际连接
&&&&&&&&&&&&&&&&&&&&if&(cs.Enable&==&true)
&&&&&&&&&&&&&&&&&&&&&&&&temp_potentRealFormPool++;
&&&&&&&&&&&&&&&&&&&&//空闲的实际连接
&&&&&&&&&&&&&&&&&&&&if&(cs.Enable&==&true&&&&cs.IsUse&==&false)
&&&&&&&&&&&&&&&&&&&&&&&&temp_spareRealFormPool++;
&&&&&&&&&&&&&&&&&&&&//已分配的实际连接
&&&&&&&&&&&&&&&&&&&&if&(cs.IsUse&==&true)
&&&&&&&&&&&&&&&&&&&&&&&&temp_useRealFormPool++;
&&&&&&&&&&&&&&&&&&&&//目前可以提供的连接数
&&&&&&&&&&&&&&&&&&&&if&(cs.Allot&==&true)
&&&&&&&&&&&&&&&&&&&&&&&&temp_spareFormPool&=&temp_spareFormPool&-&cs.RepeatN
&&&&&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&&&&&temp_spareFormPool&=&temp_spareFormPool&-&_maxRepeatD
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&}
&&&&&&&&&&&&_readOnlyFormPool&=&temp_readOnlyFormP
&&&&&&&&&&&&_potentRealFormPool&=&temp_potentRealFormP
&&&&&&&&&&&&_spareRealFormPool&=&temp_spareRealFormP
&&&&&&&&&&&&_useRealFormPool&=&temp_useRealFormP
&&&&&&&&&&&&_spareFormPool&=&temp_spareFormP
在更新属性的方法里我们把每一个属性都做了一个对应的临时变量，为的就是防止在属性更新的时候被用户程序访问到属性更新期间的不准确信息，并且在连接池中所有属性更新操作都在此进行。
&如何确定连接是否失效
&&&&&&&&/**////&&summary&
&&&&&&&&///&测试ConnStruct是否过期
&&&&&&&&///&&/summary&
&&&&&&&&///&¶m&name=&cs&&被测试的ConnStruct&/param&
&&&&&&&&private&void&TestConnStruct(ConnStruct&cs)
&&&&&&&&...{
&&&&&&&&&&&&//此次被分配出去的连接是否在此次之后失效
&&&&&&&&&&&&if&(cs.UseDegree&==&_maxRepeatDegree)
&&&&&&&&&&&&&&&&cs.SetConnectionLost();//超过使用次数
&&&&&&&&&&&&if&(cs.CreateTime.AddMinutes(_exist).Ticks&&=&DateTime.Now.Ticks)
&&&&&&&&&&&&&&&&cs.SetConnectionLost();//连接超时
&&&&/**&*//**
&&&&&*&测试ConnStruct是否过期
&&&&&*&@param&cs&ConnStruct&被测试的ConnStruct
&&&&private&void&TestConnStruct(ConnStruct&cs)&...{
&&&&&&&&//此次被分配出去的连接是否在此次之后失效
&&&&&&&&if&(cs.GetUseDegree()&==&_MaxRepeatDegree)
&&&&&&&&&&&&cs.SetConnectionLost();&//超过使用次数
&&&&&&&&Calendar&c&=&Calendar.getInstance();
&&&&&&&&c.setTime(cs.GetCreateTime());
&&&&&&&&c.set(Calendar.MINUTE,&c.get(Calendar.MINUTE)&+&_Exist);
&&&&&&&&if&(c.getTime().after(new&Date()))
&&&&&&&&&&&&cs.SetConnectionLost();&//连接超时
使用线程管理连接池
threadCreate
& 前面已经很多次的提到threadCreate和threadCheck。那它们２究竟怎么运行的呢？还是先让我们看一看threadCreate。
&&&&&&&&/**////&&summary&
&&&&&&&&///&创建线程
&&&&&&&&///&&/summary&
&&&&&&&&private&void&createThreadProcess()
&&&&&&&&...{
&&&&&&&&&&&&bool&join&=&false;
&&&&&&&&&&&&int&createThreadProcessTemp_inside&=&createThreadProcessT
&&&&&&&&&&&&_ps&=&PoolState.I
&&&&&&&&&&&&while&(true)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&join&=&false;
&&&&&&&&&&&&&&&&_ps&=&PoolState.R
&&&&&&&&&&&&&&&&if&(createThreadProcessRun&==&false)
&&&&&&&&&&&&&&&&...{//遇到终止命令
&&&&&&&&&try&...{&threadCreate.Join();&}
&&&&&&&&&&&&&&&&&&&&catch&(Exception&e)&...{&}
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&if&(createThreadMode&==&<span style="color:#)
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&//------------------------begin&mode&&创建模式
&&&&&&&&&&&& ...............在下面中说明
&&&&&&&&&&&&&&&&&&&&&&&&//------------------------end&mode
&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&else&if&(createThreadMode&==&<span style="color:#)
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&//------------------------begin&mode&&增加模式
&&&&&&&&&&&& ...............在下面中说明
&&&&&&&&&&&&&&&&&&&&&&&&//------------------------end&mode
&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&&&&&join&=&true;
&&&&&&&&&&&&&&&&&&&&//-------------------------------------------------------------------------
&&&&&&&&&&&&&&&&&&&&if&(join&==&true)
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&UpdateAttribute();//更新属性
&&&&&&&&&&&&try
&&&&&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&&&&&createThreadProcessTemp&=&<span style="color:#;
&&&&&&&&&&&&&&&&&&&&&&&&&&&&threadCreate.Join();
&&&&&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&&&&&catch&(Exception&e)
&&&&&&&&&&&&&&&&&&&&&&&&...{&createThreadProcessTemp_inside&=&createThreadProcessT&}//得到传入的变量
&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&}
在线程中每次执行循环前都要判断自己是不是被要求终止，如果自己被要求终止则无条件将自己立即阻塞上，注意线程仅仅被阻塞没有被终止。
在下面一组createThreadMode&运行模式判断中如果出现不属于０或者１的模式则放出自己被阻止的信息。
在最后线程即将被阻止时将执行更新属性操作并且将自己的运行参数设置为０，因为当运行参数为０时即使线程被唤醒，它也将不会创建任何连接，最终自己还是被阻止。
模式０模式１
threadCheck
&&&&&&&&&&&&ConnStruct&cs&=&null;
&&&&&&&&&&&&time.Stop();//关闭自己
&&&&&&&&&&&&isThreadCheckRun&=&true;
&&&&&&&&&&&&//如果正在执行创建连接则退出
&&&&&&&&&&&&if&(threadCreate.ThreadState&!=&ThreadState.WaitSleepJoin)
&&&&&&&&&&&&&&&&return;
&&&&&&&&&&&&//------------------------------------------------------
&&&&&&&&&&&&lock&(al_All)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&int&n&=&<span style="color:#;
&&&&&&&&&&&&&&&&for&(int&i&=&<span style="color:#;&i&&&al_All.C&i++)
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&cs&=&(ConnStruct)al_All[i];
&&&&&&&&&&&&&&&&&&&&TestConnStruct(cs);//测试
&&&&&&&&&&&&&&&&&&&&if&(cs.Enable&==&false&&&&cs.RepeatNow&==&<span style="color:#)//没有引用的失效连接
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&cs.Close();//关闭它
&&&&&&&&&&&&&&&&&&&&&&&&al_All.Remove(cs);//删除
&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&}
&&&&&&&&&&&&//------------------------------------------------------
&&&&&&&&&&&&UpdateAttribute();//更新属性
&&&&&&&&&&&&if&(_spareRealFormPool&&&_keepRealConnection)//保留空闲实际连接数不足
&&&&&&&&&&&&&&&&createThreadProcessTemp&=&GetNumOf(_realFormPool,&_seepConnection,&_maxConnection);
&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&createThreadProcessTemp&=&<span style="color:#;
&&&&&&&&&&&&if&(createThreadProcessTemp&!=&<span style="color:#)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&//启动创建线程，工作模式1
&&&&&&&&&&&&&&&&createThreadMode&=&<span style="color:#;
&&&&&&&&&&&&&&&&threadCreate.Interrupt();
&&&&&&&&&&&&}
&&&&&&&&&&&&isThreadCheckRun&=&false;
&&&&&&&&&&&&time.Start();//打开自己
在C#中由于Timer拥有自己的特性，所以每次触发事件的时候都将自己关闭，以保证同时只有一个事件处理过程在运行，当处理结束时在将自己打开。
threadCheck线程的最主要目的就是测试当前所有实际连接是否有满足失效的连接，如果有失效的连接就将其设置为失效，同时清理已经没有任何引用的失效连接。在做完这些操作之后它还要得到是否要创建补充的连接如果需要创建补充的连接则在将这个数值传递给threadCreate并将之启动。
其中可能出现的问题就是，如果threadCreate已经启动我们在传递参数给它那可能会引发threadCreate的处理异常，因此在threadCheck过程中会首先判断threadCreate是否在阻止中如果不在阻止状态就return等待下次threadCheck的事件。
GetNumOf是为了得到应该创建的个数，代码实现如下
&&&&&&&&/**////&&summary&
&&&&&&&&///&得到当前要增加的量
&&&&&&&&///&&/summary&
&&&&&&&&private&int&GetNumOf(int&nowNum,&int&seepNum,&int&maxNum)
&&&&&&&&...{
&&&&&&&&&&&&if&(maxNum&&=&nowNum&+&seepNum)
&&&&&&&&&&&&&&&&return&seepN
&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&return&maxNum&-&nowN
下面是threadCheck的java版，因为前文说了在Java下没有Timer类有的Timer类还仅仅在AWT下工作，因此我们要先做一个Timer类，具体如下
&&&&/**&*//**
&&&&&*&&p&检测事件&/p&
&&&&private&class&CheckThreadProcess&extends&Thread&...{
&&&&&&&&private&long&_Interval&=&<span style="color:#0;&//执行间隔
&&&&&&&&private&boolean&timeSize=false;
&&&&&&&&/**&*//**
&&&&&&&&&*&启动记时器
&&&&&&&&&*/
&&&&&&&&public&void&StartTimer()
&&&&&&&&...{
&&&&&&&&&&&&timeSize=true;
&&&&&&&&&&&&if&(this.getState()==Thread.State.NEW)
&&&&&&&&&&&&&&&&this.start();
&&&&&&&&&&&&else&if&(this.getState()==Thread.State.WAITING)
&&&&&&&&&&&&&&&&this.interrupt();
&&&&&&&&/**&*//**
&&&&&&&&&*&停止记时器
&&&&&&&&&*/
&&&&&&&&public&void&StopTimer()
&&&&&&&&...{
&&&&&&&&&&&&timeSize=false;
&&&&&&&&&&&&while(this.getState()!=Thread.State.WAITING)...{&}
&&&&&&&&public&void&aRun()
&&&&&&&&...{
&&&&&&&&public&void&run()&...{
&&&&&&&&&&&&while&(true)&...{
&&&&&&&&&&&&&&&&try&...{
&&&&&&&&&&&&&&&&&&&&this.join(_Interval);
&&&&&&&&&&&&&&&&&&&&if&(timeSize&==&true)
&&&&&&&&&&&&&&&&&&&&&&&&aRun();
&&&&&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&&&&&this.join();
&&&&&&&&&&&&&&&&}&catch&(InterruptedException&ex1)&...{&}
&&&&&&&&&&&&}
&&&&&&&&/**&*//**
&&&&&&&&&*&设置执行时间间隔
&&&&&&&&&*&@param&value&double&时间间隔
&&&&&&&&&*/
&&&&&&&&public&void&setInterval(long&value)&...{
&&&&&&&&&&&&_Interval&=&
&&&&&&&&/**&*//**
&&&&&&&&&*&获得执行时间间隔
&&&&&&&&&*&@return&double&时间间隔
&&&&&&&&&*/
&&&&&&&&public&long&getInterval()&...{
&&&&&&&&&&&&return&_I
其中aRun方法就是threadCheck在C#下的处理过程代码如下
&&&&&&&&public&void&aRun()
&&&&&&&&...{
&&&&&&&&&&&&ConnStruct&cs&=&null;
&&&&&&&&&&&&//如果正在执行创建连接则退出
&&&&&&&&&&&&if&(threadCreate.getState()&!=&Thread.State.WAITING)
&&&&&&&&&&&&&&&&return;
&&&&&&&&&&&&//------------------------------------------------------
&&&&&&&&&&&&synchronized&(al_All)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&for&(int&i&=&<span style="color:#;&i&&&al_All.size();&i++)
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&cs&=&(ConnStruct)al_All.get(i);
&&&&&&&&&&&&&&&&&&&&TestConnStruct(cs);//测试
&&&&&&&&&&&&&&&&&&&&if&(cs.GetEnable()&==&false&&&&cs.GetRepeatNow()&==&<span style="color:#)//没有引用的失效连接
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&cs.Close();//关闭它
&&&&&&&&&&&&&&&&&&&&&&&&al_All.remove(cs);//删除
&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&}
&&&&&&&&&&&&//------------------------------------------------------
&&&&&&&&&&&&UpdateAttribute();//更新属性
&&&&&&&&&&&&if&(_SpareRealFormPool&&&_KeepRealConnection)//保留空闲实际连接数不足
&&&&&&&&&&&&&&&&threadCreate.createThreadProcessTemp&=&GetNumOf(_RealFormPool,&_SeepConnection,&_MaxConnection);
&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&threadCreate.createThreadProcessTemp&=&<span style="color:#;
&&&&&&&&&&&&//if&(threadCreate.createThreadProcessTemp&!=&0)
&&&&&&&&&&&&//{
&&&&&&&&&&&&//&&&&System.out.println(&创建&&+&threadCreate.createThreadProcessTemp);
&&&&&&&&&&&&//&&&&System.out.println(threadCreate.getState()+&&&this&&&+&this.getState());
&&&&&&&&&&&&//}
&&&&&&&&&&&&if&(threadCreate.createThreadProcessTemp&!=&<span style="color:#)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&//启动创建线程，工作模式1
&&&&&&&&&&&&&&&&threadCreate.createThreadMode&=&<span style="color:#;
&&&&&&&&&&&&&&&&threadCreate.interrupt();
&&&&&&&&&&&&}
至此一个拥有引用记数，集合线程管理的数据库连接池就完成了。下面是连接池的中被包装的连接代码
&&&&/**////&&summary&
&&&&///&连接池中的一个连接类型
&&&&///&&/summary&
&&&&public&class&ConnStruct&:&IDisposable
&&&&&&&&/**////&&summary&
&&&&&&&&///&连接池中的连接
&&&&&&&&///&&/summary&
&&&&&&&&///&¶m&name=&dbc&&数据库连接&/param&
&&&&&&&&///&¶m&name=&cte&&连接类型&/param&
&&&&&&&&public&ConnStruct(DbConnection&dbc,&ConnTypeEnum&cte)
&&&&&&&&...{
&&&&&&&&&&&&createTime&=&DateTime.N
&&&&&&&&&&&&connect&=&
&&&&&&&&&&&&connType&=&
&&&&&&&&/**////&&summary&
&&&&&&&&///&连接池中的连接
&&&&&&&&///&&/summary&
&&&&&&&&///&¶m&name=&dt&&连接创建时间&/param&
&&&&&&&&///&¶m&name=&dbc&&数据库连接&/param&
&&&&&&&&///&¶m&name=&cte&&连接类型&/param&
&&&&&&&&public&ConnStruct(DbConnection&dbc,&ConnTypeEnum&cte,&DateTime&dt)
&&&&&&&&...{
&&&&&&&&&&&&createTime&=&
&&&&&&&&&&&&connect&=&
&&&&&&&&&&&&connType&=&
&&&&&&&&//--------------------------------------------------------------------
&&&&&&&&private&bool&enable&=&true;//是否失效
&&&&&&&&private&bool&use&=&false;//是否正在被使用中
&&&&&&&&private&bool&allot&=&true;//表示该连接是否可以被分配
&&&&&&&&private&DateTime&createTime&=&DateTime.N//创建时间
&&&&&&&&private&int&useDegree&=&<span style="color:#;//被使用次数
&&&&&&&&private&int&repeatNow&=&<span style="color:#;//当前连接被重复引用多少
&&&&&&&&private&bool&isRepeat&=&true;//连接是否可以被重复引用，当被分配出去的连接可能使用事务时，该属性被标识为true
&&&&&&&&private&ConnTypeEnum&connType&=&ConnTypeEnum.N//连接类型
&&&&&&&&private&DbConnection&connect&=&null;//连接对象
&&&&&&&&private&object&obj&=&null;//连接附带的信息
&&&&&&&&属性部分#region&属性部分
&&&&&&&&/**////&&summary&
&&&&&&&&///&表示该连接是否可以被分配
&&&&&&&&///&&/summary&
&&&&&&&&public&bool&Allot
&&&&&&&&...{
&&&&&&&&&&&&get&...{&return&&}
&&&&&&&&&&&&set&...{&allot&=&&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&是否失效；false表示失效，只读
&&&&&&&&///&&/summary&
&&&&&&&&public&bool&Enable
&&&&&&&&...{&get&...{&return&&}&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&是否正在被使用中，只读
&&&&&&&&///&&/summary&
&&&&&&&&public&bool&IsUse
&&&&&&&&...{&get&...{&return&&}&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&创建时间，只读
&&&&&&&&///&&/summary&
&&&&&&&&public&DateTime&CreateTime
&&&&&&&&...{&get&...{&return&createT&}&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&被使用次数，只读
&&&&&&&&///&&/summary&
&&&&&&&&public&int&UseDegree
&&&&&&&&...{&get&...{&return&useD&}&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&当前连接被重复引用多少，只读
&&&&&&&&///&&/summary&
&&&&&&&&public&int&RepeatNow
&&&&&&&&...{&get&...{&return&repeatN&}&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&得到数据库连接状态，只读
&&&&&&&&///&&/summary&
&&&&&&&&public&ConnectionState&State
&&&&&&&&...{&get&...{&return&connect.S&}&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&得到该连接，只读
&&&&&&&&///&&/summary&
&&&&&&&&public&DbConnection&Connection
&&&&&&&&...{&get&...{&return&&}&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&连接是否可以被重复引用
&&&&&&&&///&&/summary&
&&&&&&&&public&bool&IsRepeat
&&&&&&&&...{
&&&&&&&&&&&&get&...{&return&isR&}
&&&&&&&&&&&&set&...{&isRepeat&=&&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&连接类型，只读
&&&&&&&&///&&/summary&&
&&&&&&&&public&ConnTypeEnum&ConnType
&&&&&&&&...{&get&...{&return&connT&}&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&连接附带的信息
&&&&&&&&///&&/summary&
&&&&&&&&public&object&Obj
&&&&&&&&...{
&&&&&&&&&&&&get&...{&return&&}
&&&&&&&&&&&&set&...{&obj&=&&}
&&&&&&&&#endregion
&&&&&&&&/**////&&summary&
&&&&&&&&///&打开数据库连接
&&&&&&&&///&&/summary&
&&&&&&&&public&void&Open()
&&&&&&&&...{&connect.Open();&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&关闭数据库连接&
&&&&&&&&///&&/summary&
&&&&&&&&public&void&Close()
&&&&&&&&...{&connect.Close();&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&无条件将连接设置为失效
&&&&&&&&///&&/summary&
&&&&&&&&public&void&SetConnectionLost()
&&&&&&&&...{&enable&=&false;&allot&=&false;&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&被分配出去，线程安全的
&&&&&&&&///&&/summary&
&&&&&&&&public&void&Repeat()
&&&&&&&&...{
&&&&&&&&&&&&lock&(this)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&if&(enable&==&false)//连接可用
&&&&&&&&&&&&&&&&&&&&throw&new&ResLostnExecption();//连接资源已经失效
&&&&&&&&&&&&&&&&if&(allot&==&false)//是否可以被分配
&&&&&&&&&&&&&&&&&&&&throw&new&AllotExecption();//连接资源不可以被分配
&&&&&&&&&&&&&&&&if&(use&==&true&&&&isRepeat&==&false)
&&&&&&&&&&&&&&&&&&&&throw&new&AllotAndRepeatExecption();//连接资源已经被分配并且不允许重复引用
&&&&&&&&&&&&&&&&repeatNow++;//引用记数+1
&&&&&&&&&&&&&&&&useDegree++;//被使用次数+1
&&&&&&&&&&&&&&&&use&=&true;//被使用
&&&&&&&&&&&&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&被释放回来，线程安全的
&&&&&&&&///&&/summary&
&&&&&&&&public&void&Remove()
&&&&&&&&...{
&&&&&&&&&&&&lock&(this)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&if&(enable&==&false)//连接可用
&&&&&&&&&&&&&&&&&&&&throw&new&ResLostnExecption();//连接资源已经失效
&&&&&&&&&&&&&&&&if&(repeatNow&==&<span style="color:#)
&&&&&&&&&&&&&&&&&&&&throw&new&RepeatIsZeroExecption();//引用记数已经为0
&&&&&&&&&&&&&&&&repeatNow--;//引用记数-1
&&&&&&&&&&&&&&&&if&(repeatNow&==&<span style="color:#)
&&&&&&&&&&&&&&&&&&&&use&=&false;//未使用
&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&use&=&true;//使用中
&&&&&&&&&&&&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&释放资源
&&&&&&&&///&&/summary&
&&&&&&&&public&void&Dispose()
&&&&&&&&...{
&&&&&&&&&&&&enable&=&false;
&&&&&&&&&&&&connect.Close();
&&&&&&&&&&&&connect&=&null;
上面代码的Java实现
///&&summary&
///&连接池中的一个连接类型
///&&/summary&
public&class&ConnStruct&...{
&&&&private&boolean&_enable&=&true;&//是否失效
&&&&private&boolean&_isUse&=&false;&//是否正在被使用中
&&&&private&boolean&_allot&=&true;&//表示该连接是否可以被分配
&&&&private&Date&_createT&//创建时间
&&&&private&int&_useDegree&=&<span style="color:#;&//被使用次数
&&&&private&int&_repeatNow&=&<span style="color:#;&//当前连接被重复引用多少
&&&&private&boolean&_isRepeat&=&true;&//连接是否可以被重复引用，当被分配出去的连接可能使用事务时，该属性被标识为true
&&&&private&int&_connT&//连接类型
&&&&private&Connection&_connect&=&null;&//连接对象
&&&&/**&*//**
&&&&&*&连接池中的连接
&&&&&*&@param&dbc&Connection&数据库连接
&&&&public&ConnStruct(Connection&dbc)&...{
&&&&&&&&InitConnStruct(dbc,&new&Date());
&&&&/**&*//**
&&&&&*&连接池中的连接
&&&&&*&@param&dbc&Connection&&数据库连接
&&&&&*&@param&dt&Date&连接创建时间
&&&&public&ConnStruct(Connection&dbc,&Date&dt)&...{
&&&&&&&&InitConnStruct(dbc,&dt);
&&&&/**&*//**
&&&&&*&连接池中的连接
&&&&&*&@param&dbc&Connection&&数据库连接
&&&&&*&@param&dt&Date&连接创建时间
&&&&private&void&InitConnStruct(Connection&dbc,&Date&dt)&...{
&&&&&&&&_createTime&=&
&&&&&&&&_connect&=&
&&&&//--------------------------------------------------------------------
&&&&/**&*//**
&&&&&*&得到一个值表示该连接是否可以被分配
&&&&&*&@return&boolean&该连接是否可以被分配
&&&&public&boolean&GetAllot()&...{
&&&&&&&&return&_
&&&&/**&*//**
&&&&&*&设置一个值表示该连接是否可以被分配
&&&&&*&@param&value&boolean&true可以被分配，false不可以被分配
&&&&public&void&SetAllot(boolean&value)&...{
&&&&&&&&_allot&=&
&&&&/**&*//**
&&&&&*&得到当前连接是否失效
&&&&&*&@return&boolean&得到当前连接是否失效；false表示失效，只读
&&&&public&boolean&GetEnable()&...{
&&&&&&&&return&_
&&&&/**&*//**
&&&&&*&得到当前连接是否正在被使用中，只读
&&&&&*&@return&boolean&当前连接是否正在被使用中
&&&&public&boolean&GetIsUse()&...{
&&&&&&&&return&_isU
&&&&/**&*//**
&&&&&*&得到连接创建时间，只读
&&&&&*&@return&Date&创建时间
&&&&public&Date&GetCreateTime()&...{
&&&&&&&&return&_createT
&&&&/**&*//**
&&&&&*&得到被使用次数，只读
&&&&&*&@return&int&得到被使用次数
&&&&public&int&GetUseDegree()&...{
&&&&&&&&return&_useD
&&&&/**&*//**
&&&&&*&得到当前连接被重复引用多少，只读
&&&&&*&@return&int&当前连接被重复引用多少
&&&&public&int&GetRepeatNow()&...{
&&&&&&&&return&_repeatN
&&&&/**&*//**
&&&&&*&得到该连接，只读
&&&&&*&@return&Connection&连接
&&&&public&Connection&GetConnection()&...{
&&&&&&&&return&_
&&&&/**&*//**
&&&&&*&得到连接是否可以被重复引用
&&&&&*&@return&boolean&是否可以被重复引用
&&&&public&boolean&GetIsRepeat()&...{
&&&&&&&&return&_isR
&&&&/**&*//**
&&&&&*&设置连接是否可以被重复引用
&&&&&*&@param&value&boolean&true可以被重复引用，false不可以被重复引用
&&&&public&void&SetIsRepeat(boolean&value)&...{
&&&&&&&&_isRepeat&=&
&&&&/**&*//**
&&&&&*&得到连接类型ConnectionPool.ConnType_*，只读
&&&&&*&@return&int&连接类型
&&&&public&int&GetConnType()&...{
&&&&&&&&return&_connT
&&&&/**&*//**
&&&&&*&关闭数据库连接
&&&&public&void&Close()&...{
&&&&&&&&try&...{
&&&&&&&&&&&&_connect.close();
&&&&&&&&}&catch&(Exception&e)&...{}
&&&&/**&*//**
&&&&&*&无条件将连接设置为失效
&&&&public&void&SetConnectionLost()&...{
&&&&&&&&_enable&=&false;
&&&&&&&&_allot&=&false;
&&&&/**&*//**
&&&&&*&被分配出去，线程安全的
&&&&&*&@throws&ResLostnExecption
&&&&&*&@throws&AllotExecption
&&&&&*&@throws&AllotAndRepeatExecption
&&&&public&synchronized&void&Repeat()&throws&ResLostnException,&AllotException,
&&&&&&&&&&&&AllotAndRepeatException&...{
&&&&&&&&if&(_enable&==&false)&//连接可用
&&&&&&&&&&&&throw&new&ResLostnException();&//连接资源已经失效
&&&&&&&&if&(_allot&==&false)&//是否可以被分配
&&&&&&&&&&&&throw&new&AllotException();&//连接资源不可以被分配
&&&&&&&&if&(_isUse&==&true&&&&_isRepeat&==&false)
&&&&&&&&&&&&throw&new&AllotAndRepeatException();&//连接资源已经被分配并且不允许重复引用
&&&&&&&&_repeatNow++;&//引用记数+1
&&&&&&&&_useDegree++;&//被使用次数+1
&&&&&&&&_isUse&=&true;&//被使用
&&&&/**&*//**
&&&&&*&被释放回来，线程安全的
&&&&&*&@throws&ResLostnExecption&连接资源已经失效
&&&&&*&@throws&RepeatIsZeroExecption&引用记数已经为0
&&&&public&synchronized&void&Remove()&throws&ResLostnException,
&&&&&&&&&&&&RepeatIsZeroException&...{
&&&&&&&&if&(_enable&==&false)&//连接可用
&&&&&&&&&&&&throw&new&ResLostnException();&//连接资源已经失效
&&&&&&&&if&(_repeatNow&==&<span style="color:#)
&&&&&&&&&&&&throw&new&RepeatIsZeroException();&//引用记数已经为0
&&&&&&&&_repeatNow--;&//引用记数-1
&&&&&&&&if&(_repeatNow&==&<span style="color:#)
&&&&&&&&&&&&_isUse&=&false;&//未使用
&&&&&&&&else
&&&&&&&&&&&&_isUse&=&true;&//使用中
&&&&///&&summary&
&&&&///&释放资源
&&&&///&&/summary&
&&&&public&void&Dispose()&...{
&&&&&&&&_enable&=&false;
&&&&&&&&try&...{
&&&&&&&&&&&&_connect.close();
&&&&&&&&}&catch&(Exception&e)&...{}
&&&&&&&&_connect&=&null;
lock&(al_All)
if&(al_All.Count&&&createThreadProcessTemp_inside)
al_All.Add(CreateConnection(_connString,&_connType));
join&=&true;
在模式０中线程将一直创建连接，直到被创建的连接达到最小连接数目，具体实现方法是将最小要创建的连接存入al_All，直到al_All的元素个数达到最小连接数才放出自己被阻止的消息。
lock&(al_All)
if&(createThreadProcessTemp_inside&!=&<span style="color:#)
createThreadProcessTemp_inside--;
al_All.Add(CreateConnection(_connString,&_connType));
join&=&true;
在模式１中线程将一直创建连接，直到被创建的连接达到被要求的连接数目，具体实现方法是将最小要创建的连接存入createThreadProcessTemp_inside临时变量，然后每次创建一个连接就自减１直至到０时放出自己被阻止的消息。
以下是java的代码实现
&&&&/**&*//**
&&&&&*&&p&创建线程类&/p&
&&&&private&class&CreateThreadProcess&extends&Thread&...{
&&&&&&&&public&int&createThreadMode&=&<span style="color:#;&//创建线程工作模式
&&&&&&&&public&int&createThreadProcessTemp&=&<span style="color:#;&//需要创建的连接数
&&&&&&&&public&boolean&createThreadProcessRun&=&false;&//是否决定创建线程将继续工作，如果不继续工作则线程会将自己处于阻止状态
&&&&&&&&public&void&run()&...{
&&&&&&&&&&&&boolean&join&=&false;
&&&&&&&&&&&&int&createThreadProcessTemp_inside&=&createThreadProcessT
&&&&&&&&&&&&_PoolState&=&PoolState_I
&&&&&&&&&&&&while&(true)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&join&=&false;
&&&&&&&&&&&&&&&&_PoolState&=&PoolState_R
&&&&&&&&&&&&&&&&if&(createThreadProcessRun&==&false)
&&&&&&&&&&&&&&&&...{//遇到终止命令
&&&&&&&&&&&&&&&&&&&&try&...{
&&&&&&&&&&&&&&&&&&&&&&&&this.join();//中断自己
&&&&&&&&&&&&&&&&&&&&}&catch&(Exception&e)&...{/**//*&*/}
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&if&(createThreadMode&==&<span style="color:#)
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&//------------------------begin&mode&&创建模式
&&&&&&&&&&&&&&&&&&&&&&&&synchronized&(al_All)
&&&&&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&&&&&if&(al_All.size()&&&createThreadProcessTemp_inside)
&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&al_All.add(CreateConnectionTemp(_ConnString,_DriveString,_userID,_password));
&&&&&&&&&&&&&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&join&=&true;
&&&&&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&&&&&//------------------------end&mode
&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&else&if&(createThreadMode&==&<span style="color:#)
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&//------------------------begin&mode&&增加模式
&&&&&&&&&&&&&&&&&&&&&&&&synchronized&(al_All)
&&&&&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&&&&&if&(createThreadProcessTemp_inside&!=&<span style="color:#)
&&&&&&&&&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&createThreadProcessTemp_inside--;
&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&al_All.add(CreateConnectionTemp(_ConnString,_DriveString,_userID,_password));
&&&&&&&&&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&join&=&true;
&&&&&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&&&&&//------------------------end&mode
&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&&&&&join&=&true;
&&&&&&&&&&&&&&&&&&&&//-------------------------------------------------------------------------
&&&&&&&&&&&&&&&&&&&&if&(join&==&true)
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&UpdateAttribute();//更新属性
&&&&&&&&&&&&&&&&&&&&&&&&try&...{
&&&&&&&&&&&&&&&&&&&&&&&&&&&&createThreadProcessTemp&=&<span style="color:#;
&&&&&&&&&&&&&&&&&&&&&&&&&&&&this.join();&//中断自己
&&&&&&&&&&&&&&&&&&&&&&&&}&catch&(Exception&e)&...{
&&&&&&&&&&&&&&&&&&&&&&&&&&&&createThreadProcessTemp_inside&=&createThreadProcessT
&&&&&&&&&&&&&&&&&&&&&&&&}&//得到传入的变量
&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&}
文章主要讨论了如何编写一个高效的数据库连接池，包括多种数据库的支持引用记数的应用，截止文章发表为止，该连接池已经发现潜在问题诸多，比如在长时间运行中threadCheck和threadCreate线程的运行可能会不稳定，那导致的问题是致命的，关于解决问题么可能还要加入线程池？或者在启动停止服务时候创建销毁它们？如果你有更好的办法请发表评论。以便于我继续改进。
另一个以发现的问题就是连接池没有对数据库连接状态做跟踪，这个对于我是失败的问题，在设计它时直到日发布之前都没有考虑到这个因素，郁闷
另外我想说的就是这个小东西虽然不是很多代码，但是菜鸟的我也弄了２个来月所以请转贴时注明出处和作者。
还有一点想说的是即使把代码放上来也不见得是极其完整的代码，如果有想要原代码的朋友请发邮件到我的邮箱，邮箱下面有写。
作者:赵永春
此处为日更新说明:本文所讲连接池有所升级,具体请参看
日追加更新 SVN地址，在使用SVN时可能需要你输入帐号密码，请在svnhost中注册一个帐号在下载源码。
java版本源码下载：
.net版本源码下载：
参考文献：《基于JDBC的数据库连接池高效管理策略》来源网络。
* 以上用户言论只代表其个人观点，不代表CSDN网站的观点或立场
访问：110150次
积分：1515
积分：1515
排名：第11217名
原创：21篇
转载：116篇
评论：39条
(1)(3)(1)(2)(3)(6)(3)(1)(16)(3)(3)(1)(6)(8)(8)(5)(14)(3)(3)(1)(22)(14)(6)(1)(1)(5)(4)(5)(2)(4)(1)}
如何实现事务处理
&管理连接池
结合代码说明
启动服务StartService
停止服务StopService
申请&GetConnectionFormPool
释放DisposeConnection
如何更新属性
如何确定连接是否失效
使用线程管理连接池
threadCreate
threadCheck
步骤.在着一步骤中我们经常是,打开数据库连接操作数据库,最后关闭数据库.
,网上有很多的连接池例子,但是多数都是简单的例子,或者介绍比较复杂的连接池原理,没有一个比较完整介绍和实现连接池的例子.这里就介绍你如何自己制作一个连接池.
&连接池关键问题分析
）；如果没有就抛出一个异常给用户，List中连接是否可以被分配由一个线程来专门管理捎后我会介绍这个线程的具体实现。
在分配、释放策略对于有效复用连接非常重要，我们采用的方法也是采用了一个很有名的设计模式：Reference Counting（引用记数）。该模式在复用资源方面用的非常广泛，我们把该方法运用到对于连接的分配释放上。每一个数据库连接，保留一个引用记数，用来记录该连接的使用者的个数。具体的实现上，我们对Connection类进行进一步包装来实现引用记数。被包装的Connection类我们提供２个方法来实现引用记数的操作，一个是Repeat（被分配出去）Remove（被释放回来）；然后利用RepeatNow属性来确定当前被引用多少，具体是哪个用户引用了该连接将在连接池中登记；最后提供IsRepeat属性来确定该连接是否可以使用引用记数技术。一旦一个连接被分配出去，那么就会对该连接的申请者进行登记，并且增加引用记数，当被释放回来时候就删除他已经登记的信息，同时减少一次引用记数。
这样做有一个很大的好处，使得我们可以高效的使用连接，因为一旦所有连接都被分配出去，我们就可以根据相应的策略从使用池中挑选出一个已经正在使用的连接用来复用，而不是随意拿出一个连接去复用。策略可以根据需要去选择，我们有４策略可是使用：
１.ConnLevel_ReadOnly 独占方式
使用空闲的实际连接分配连接资源，并且在该资源释放回之前，该资源在连接池中将不能将其引用分配给其他申请者。如果连接池中所有实际连接资源都已经分配出去，那么即使连接池可以在分配引用资源在该模式下连接迟将不会分配连接资源，连接池会产生一个异常，标志连接池资源耗尽。
例：假如一个实际连接可以被分配5次，那么使用该模式申请连接的话您将损失4个可分配的连接，只将得到一个连接资源。 直至该资源被释放回连接池，连接池才继续分配它剩余的4次机会。
当你在使用连接时可能应用到事务时，可以使用该模式的连接，以确定在事务进行期间您可以对该连接具有独享权限，以避免各个数据库操作访问的干扰。
２.ConnLevel_High 优先级-高
使用空闲的实际连接分配连接资源，并且在该资源释放回之前，该资源在连接池中将可能将其引用分配给其他申请者。*注意：此级别不保证在分配该资源后，仍然保持独立占有连接资源，若想独立占有资源请使用ReadOnely， 因为当连接池达到某一时机时该资源将被重复分配（引用记数）然而这个时机是不可预测的。如果您申请的连接会用于事务处理您可以使用ConnLevel_ReadOnly级别。
３.ConnLevel_None 优先级-中
适当应用引用记数技术分配连接资源。
在该模式下，连接池内部会按照实际连接已经使用次数排序(多-&少)，然后在结果中选取 1/3 位置的连接资源返回。与优先级-高相同该模式也不具备保持独立占有连接资源的特性。如果您申请的连接会用于事务处理您可以使用ConnLevel_ReadOnly级别。
４.ConnLevel_Bottom 优先级-底
尽可能使用引用记数技术分配连接。在该模式下，连接池内部会按照实际连接已经使用次数排序(多-&少)，然后在结果中选取被使用最多的返回。该模式适合处理较为不重要的连接资源请求。与优先级-高相同该模式也不具备保持独立占有连接资源的特性。如果您申请的连接会用于事务处理您可以使用ConnLevel_ReadOnly级别。
以上4条策略选自datebasepool_SDK（datebasepool是本文所开发的最终产物）
如何实现事务处理
& 前面谈到的都是关于使用数据库连接进行普通的数据库访问。对于事务处理，情况就变得比较复杂。因为事务本身要求原子性的保证，此时就要求对于数据库的操作符合&All-All-Nothing&原则，即要么全部完成，要么什么都不做。如果简单的采用上述的连接复用的策略，就会发生问题，因为没有办法控制属于同一个事务的多个数据库操作方法的动作，可能这些数据库操作是在多个连接上进行的，并且这些连接可能被其他非事务方法复用。
Connection本身具有提供了对于事务的支持，具体实现方法请参看Connection的msdn，显式的调用commit或者rollback方法来实现。但是要安全、高效的进行Connection进行复用，就必须提供相应的事务支持机制。我们采用的方法是：用户以ConnLevel_ReadOnly模式申请一个连接之后该连接就由该申请者独自享有该连接，具体事务操作由用户自行设计编写，连接池只提供用户独自占有。
&管理连接池
在上文中我们说过这个连接池内部连接管理使用的是独立的线程来工作（threadCreate和threadCheck）threadCreate线程负责创建连接&，threadCheck线程负责检查每个连接是否达到自己的寿命，标志连接寿命的条件是被引用的次数超过它最大被引用次数，或者达到最大生存时间。这些参数都由ConnStruct类管理，ConnStruct类是包装连接的类，下面定义的就是连接池使用到的属性变量(C#代码)
&&&&&&&&//属性
&&&&&&&&private&int&_realFormP//连接池中存在的实际连接数(包含失效的连接)
&&&&&&&&private&int&_potentRealFormP//连接池中存在的实际连接数(有效的实际连接)
&&&&&&&&private&int&_spareRealFormP//空闲的实际连接
&&&&&&&&private&int&_useRealFormP//已分配的实际连接
&&&&&&&&private&int&_readOnlyFormP//连接池已经分配多少只读连接
&&&&&&&&private&int&_useFormP//已经分配出去的连接数
&&&&&&&&private&int&_spareFormP//目前可以提供的连接数
&&&&&&&&private&int&_maxC//最大连接数，最大可以创建的连接数目
&&&&&&&&private&int&_minC//最小连接数
&&&&&&&&private&int&_seepC//每次创建连接的连接数
&&&&&&&&private&int&_keepRealC//保留的实际空闲连接，以攻可能出现的ReadOnly使用，当空闲连接不足该数值时，连接池将创建seepConnection个连接
&&&&&&&&private&int&_exist&=&<span style="color:#;//每个连接生存期限&20分钟
&&&&&&&&private&int&_maxRepeatDegree&=&<span style="color:#;//可以被重复使用次数（引用记数），当连接被重复分配该值所表示的次数时，该连接将不能被分配出去
&&&&&&&&//当连接池的连接被分配尽时，连接池会在已经分配出去的连接中，重复分配连接（引用记数）。来缓解连接池压力
&&&&&&&&private&DateTime&_startT//服务启动时间
&&&&&&&&private&string&_connString&=&null;//连接字符串
&&&&&&&&private&ConnTypeEnum&_connT//连接池连接类型
&&&&&&&&private&PoolState&_//连接池状态
&&&&&&&&//内部对象
&&&&&&&&private&ArrayList&al_All&=&new&ArrayList();//实际连接
&&&&&&&&private&Hashtable&hs_UseConn&=&new&Hashtable();//正在使用的连接
&&&&&&&&private&System.Timers.Timer&//监视器记时器
&&&&&&&&private&Thread&threadC//创建线程
&&&&&&&&private&bool&isThreadCheckRun&=&false;
&&&&//属性
&&&&private&int&_RealFormP&//连接池中存在的实际连接数(包含失效的连接)
&&&&private&int&_PotentRealFormP&//连接池中存在的实际连接数(有效的实际连接)
&&&&private&int&_SpareRealFormP&//空闲的实际连接
&&&&private&int&_UseRealFormP&//已分配的实际连接
&&&&private&int&_ReadOnlyFormP&//连接池已经分配多少只读连接
&&&&private&int&_UseFormP&//已经分配出去的连接数
&&&&private&int&_SpareFormP&//目前可以提供的连接数
&&&&private&int&_MaxC&//最大连接数，最大可以创建的连接数目
&&&&private&int&_MinC&//最小连接数
&&&&private&int&_SeepC&//每次创建连接的连接数
&&&&private&int&_KeepRealC&//保留的实际空闲连接，以攻可能出现的ReadOnly使用，当空闲连接不足该数值时，连接池将创建seepConnection个连接
&&&&private&int&_Exist&=&<span style="color:#;&//每个连接生存期限&20分钟
&&&&private&String&_userID=&&;
&&&&private&String&_password=&&;
&&&&//可以被重复使用次数（引用记数），当连接被重复分配该值所表示的次数时，该连接将不能被分配出去
&&&&//当连接池的连接被分配尽时，连接池会在已经分配出去的连接中，重复分配连接（引用记数）。来缓解连接池压力
&&&&private&int&_MaxRepeatDegree&=&<span style="color:#;
&&&&private&Date&_StartT&//服务启动时间
&&&&private&String&_ConnString&=&null;&//连接字符串
&&&&private&String&_DriveString&=&null;&//驱动字符串
&&&&private&int&_PoolS&//连接池状态
&&&&//内部对象
&&&&private&ArrayList&al_All&=&new&ArrayList();&//实际连接
&&&&private&Hashtable&hs_UseConn&=&new&Hashtable();&//正在使用的连接
&&&&private&CreateThreadProcess&threadC
&&&&private&CheckThreadProcess&threadC
当用户调用连接池的StartService方法时，在StartService方法中会通知threadCreate线程创建静态连接，然后将这些静态连接加入到List，同时启动threadCheck线程，threadCheck线程负责检测List中的最小空闲连接是否少于连接池配置的最少空闲连接数，当条件为真时threadCheck线程会负责再次唤醒threadCreate线程同时给threadCreate线程传递这次要创建的连接个数。
对于threadCreate线程有２种工作模式，模式０为初始化创建模式，该模式会创建连接迟池配置的最小连接数目；模式１即每隔一定时间就对连接池进行检测，如果发现连接数量小于最小连接数，则补充相应数量的新连接时的工作模式。
申请连接，当用户申请连接时必须指定一个发起者和一个申请优先级别，优先级由ConnLevel_*系列指定。一旦用户从连接池中申请到一个连接时就将申请到的连接引用和申请者，同时加入到HashTable来注册到连接池。
释放连接，将注册的用户删除。&&
&下面是代码说明
共有Java和C#２个版本，２版本可能捎有不同因为各个语言有自己的特点
Java版本的构造方法
&&&&public&ConnectionPool()&...{
&&&&&&&&InitConnectionPool(&&,&&&,&<span style="color:#0,&<span style="color:#,&<span style="color:#,&<span style="color:#);
&&&&public&ConnectionPool(String&connectionString,&String&driveString)&...{
&&&&&&&&InitConnectionPool(connectionString,&driveString,&<span style="color:#0,&<span style="color:#,&<span style="color:#,&<span style="color:#);
&&&&public&ConnectionPool(String&connectionString,&String&driveString,&int&maxConnection,&int&minConnection)&...{
&&&&&&&&InitConnectionPool(connectionString,&driveString,&maxConnection,&minConnection,&<span style="color:#,&<span style="color:#);
&&&&public&ConnectionPool(String&connectionString,&String&driveString,&int&maxConnection,&int&minConnection,&int&seepConnection,&int&keepRealConnection)&...{
&&&&&&&&InitConnectionPool(connectionString,&driveString,&maxConnection,&minConnection,&seepConnection,&keepRealConnection);
C#版本的构造方法
&&&&&&&&public&ConnectionPool(string&connectionString)
&&&&&&&&...{&InitConnectionPool(connectionString,&ConnTypeEnum.Odbc,&<span style="color:#0,&<span style="color:#,&<span style="color:#,&<span style="color:#,&<span style="color:#);&}
&&&&&&&&public&ConnectionPool(string&connectionString,&ConnTypeEnum&cte)
&&&&&&&&...{&InitConnectionPool(connectionString,&cte,&<span style="color:#0,&<span style="color:#,&<span style="color:#,&<span style="color:#,&<span style="color:#);&}
&&&&&&&&public&ConnectionPool(string&connectionString,&ConnTypeEnum&cte,&int&maxConnection,&int&minConnection)
&&&&&&&&...{&InitConnectionPool(connectionString,&cte,&maxConnection,&minConnection,&<span style="color:#,&<span style="color:#,&<span style="color:#);&}
&&&&&&&&public&ConnectionPool(string&connectionString,&ConnTypeEnum&cte,&int&maxConnection,&int&minConnection,&int&seepConnection,&int&keepConnection)
&&&&&&&&...{&InitConnectionPool(connectionString,&cte,&maxConnection,&minConnection,&seepConnection,&keepConnection,&<span style="color:#);&}
&&&&&&&&public&ConnectionPool(string&connectionString,&ConnTypeEnum&cte,&int&maxConnection,&int&minConnection,&int&seepConnection,&int&keepConnection,&int&keepRealConnection)
&&&&&&&&...{&InitConnectionPool(connectionString,&cte,&maxConnection,&minConnection,&seepConnection,&keepConnection,&keepRealConnection);&}
上面２个版本的构造方法都调用InitConnectionPool方法，下面是InitConnectionPool方法实现(C#)
&&&&&&&&/**////&&summary&
&&&&&&&&///&初始化函数
&&&&///&&/summary&
&&&&&&&&protected&void&InitConnectionPool(string&connectionString,&ConnTypeEnum&cte,&int&maxConnection,&int&minConnection,&int&seepConnection,&int&keepConnection,&int&keepRealConnection)
&&&&&&&&...{
&&&&&&&&&&&&if&(cte&==&ConnTypeEnum.None)
&&&&&&&&&&&&&&&&throw&new&ConnTypeExecption();//参数不能是None
&&&&&&&&&&&&_ps&=&PoolState.UnI
&&&&&&&&&&&&this._connString&=&connectionS
&&&&&&&&&&&&this._connType&=&
&&&&&&&&&&&&this._minConnection&=&minC
&&&&&&&&&&&&this._seepConnection&=&seepC
&&&&&&&&&&&&this._keepRealConnection&=&keepRealC
&&&&&&&&&&&&this._maxConnection&=&maxC
&&&&&&&&&&&&this.time&=&new&System.Timers.Timer(<span style="color:#0);
&&&&&&&&&&&&this.time.Stop();
&&&&&&&&&&&&this.time.Elapsed&+=&new&System.Timers.ElapsedEventHandler(time_Elapsed);
&&&&&&&&&&&&this.threadCreate&=&new&Thread(new&ThreadStart(createThreadProcess));
& 在InitConnectionPool方法中我们定义了连接池要连接的数据库类型ConnTypeEnum&cte，和连接字符串stringconnectionString等类型，在方法最后注册了Timer类的Elapsed&事件，在C#版中Timer类就充当threadCheck线程，而Elapsed事件就是线程threadCheck的执行方法体。
由于刚刚初始化连接池对象故threadCheck线程不需要运行所以在InitConnectionPool方法中将Timer关闭。下面是java实现：&&&
&&&&private&void&InitConnectionPool(String&connectionString,&String&driveString,&int&maxConnection,&int&minConnection,&int&seepConnection,&int&keepRealConnection)&...{
&&&&&&&&this._PoolState&=&PoolState_UnI
&&&&&&&&this._ConnString&=&connectionS
&&&&&&&&this._DriveString&=&driveS
&&&&&&&&this._MinConnection&=&minC
&&&&&&&&this._SeepConnection&=&seepC
&&&&&&&&this._KeepRealConnection&=&keepRealC
&&&&&&&&this._MaxConnection&=&maxC
&&&&&&&&this.threadCheck&=&new&CheckThreadProcess();
&&&&&&&&this.threadCheck.setDaemon(true);
&&&&&&&&this.threadCreate&=&new&CreateThreadProcess();
&&&&&&&&this.threadCreate.setDaemon(true);
&&&&&&&&this.threadCheck.start();
&&&&while(threadCheck.getState()!=Thread.State.WAITING)...{}
由于Java中的Timer类需要AWT 的GUI线程组建支持，总不能在我们的连接池中开辟一个Form出来把，因此在Java版本中使用线程来实现Timer，在Java版本中threadCheck一开始就被启动，然后又等待threadCheck线程自己被阻塞又是为什么呢，这样做是为了实现C#版本中stop方法.（由于个人原因这个连接池最初是由C#.Net2.0开发而成的故而在Java中可能存在许多设计不合理）。
由上面代码可以看出一旦连接池被创建出来以后就已经运行了一个threadCheck线程(对于Java版)，而这个线程将立刻进入WAITING等待状态。
&启动服务StartService
&&&&&&&&/**////&&summary&
&&&&&&&&///&启动服务，线程安全
&&&&&&&&///&&/summary&
&&&&&&&&public&void&StartServices()
&&&&&&&&...{
&&&&&&&&&&&&lock&(this)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&createThreadMode&=&<span style="color:#;//工作模式0
&&&&&&&&&&&&&&&&createThreadProcessRun&=&true;
&&&&&&&&&&&&&&&&createThreadProcessTemp&=&_minC
&&&&&&&&&&&&&&&&if&(_ps&==&PoolState.UnInitialize)
&&&&&&&&&&&&&&&&&&&&threadCreate.Start();
&&&&&&&&&&&&&&&&else&if&(_ps&==&PoolState.Stop)
&&&&&&&&&&&&&&&&&&&&threadCreate.Interrupt();
&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&throw&new&PoolNotStopException();//服务已经运行或者未完全结束
&&&&&&&&&&&&&&&&time.Start();
&&&&&&&&&&&&}
createThreadMode&是设置threadCreate的工作模式为０创建模式，前面我们说过threadCreate有２种工作模式，如果忘记了就回头去看看把。
createThreadProcessTemp是threadCreate工作需要的参数变量threadCreate会在0或者1这两种工作模式下用到这个临时变量该变量作用就是告诉threadCreate要创建多少个连接，下面的一组if ....&else 是为了将threadCreate线程运行起来 _ps是表示当前连接池状态，下面是_ps的定义，在Java版本中PoolState只是一组public static final int故在这里不在将源码放出。
在StartServices最后我们启动了time也就是threadCheck线程。
&&&&//&连接池状态
&&&&public&enum&PoolState
&&&&&&&&UnInitialize,//&刚刚创建的对象，表示该对象未被调用过StartSeivice方法。
&&&&&&&&Initialize,//&初始化中，该状态下服务正在按照参数初始化连接池。
&&&&&&&&Run,//运行中
&&&&&&&&Stop//停止状态
PoolState定义
&&&/**&*//**
&&&&&*&启动连接池服务
&&&&&*&@throws&PoolNotStopException&服务已经运行或者未完全结束
&&&&public&void&StartServices()&throws&PoolNotStopException&...{
&&&&&&&&synchronized&(this)&...{
&&&&&&&&&&&&threadCreate.createThreadMode&=&<span style="color:#;&//工作模式0
&&&&&&&&&&&&threadCreate.createThreadProcessRun&=&true;
&&&&&&&&&&&&threadCreate.createThreadProcessTemp&=&_MinC
&&&&&&&&&&&&if&(_PoolState&==&PoolState_UnInitialize)
&&&&&&&&&&&&&&&&threadCreate.start();
&&&&&&&&&&&&else&if&(_PoolState&==&PoolState_Stop)
&&&&&&&&&&&&&&&&threadCreate.interrupt();
&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&throw&new&PoolNotStopException();&//服务已经运行或者未完全结束
&&&&&&&&&&&&threadCheck.StartTimer();
&&&&&&&&&&&&threadCheck.interrupt();//开始运行
&停止服务StopService
&&&&&&&&/**////&&summary&
&&&&&&&&///&停止服务，线程安全
&&&&&&&&///&&/summary&
&&&&&&&&public&void&StopServices()
&&&&&&&&...{&StopServices(false);&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&停止服务，线程安全
&&&&&&&&///&¶m&name=&needs&&是否必须退出；如果指定为false与StartServices()功能相同，如果指定为true。将未收回的连接资源关闭，这将是危险的。认为可能你的程序正在使用此资源。&/param&
&&&&&&&&///&&/summary&
&&&&&&&&public&void&StopServices(bool&needs)
&&&&&&&&...{
&&&&&&&&&&&&lock&(this)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&if&(_ps&==&PoolState.Run)
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&lock&(hs_UseConn)
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&if&(needs&==&true)//必须退出
&&&&&&&&&&&&&&&&&&&&&&&&&&&&hs_UseConn.Clear();
&&&&&&&&&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&&&&&&&&&if&(hs_UseConn.Count&!=&<span style="color:#)
&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&throw&new&ResCallBackException();//连接池资源未全部回收
&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&time.Stop();
&&&&&&&&&&&&&&&&&&&&while&(isThreadCheckRun)&...{&}//等待timer事件结束
&&&&&&&&&&&&&&&&&&&&createThreadProcessRun&=&false;
&&&&&&&&&&&&&&&&&&&&while&(threadCreate.ThreadState&!=&ThreadState.WaitSleepJoin)&...{&}//等待可能存在的创建线程结束
&&&&&&&&&&&&&&&&&&&&lock&(al_All)
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&for&(int&i&=&<span style="color:#;&i&&&al_All.C&i++)
&&&&&&&&&&&&&&&&&&&&&&&&&&&&((ConnStruct)al_All[i]).Dispose();
&&&&&&&&&&&&&&&&&&&&&&&&al_All.Clear();
&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&_ps&=&PoolState.S
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&throw&new&PoolNotRunException();//服务未启动
&&&&&&&&&&&&}
&&&&&&&&&&&&UpdateAttribute();//更新属性
在这里我们使用了2层锁第一层锁我们是为了保证同一时间只能有一个线程调用这个方法，而lock&(hs_UseConn)则是为了保护hs_UseConn的唯一访问hs_UseConn存放的就是申请连接时注册信息，needs是将未收回的连接资源也关闭，这将是危险的。认为可能你的程序正在使用此资源。
if&(hs_UseConn.Count&!=&<span style="color:#)
&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&throw&new&ResCallBackException();//连接池资源未全部回收。
这段代码是表示如果用户试图在连接没有全部释放回来时候将会引发异常，同时执行该方法的必要条件是连接池必须处在PoolState_Run状态。
time.Stop();是停止检测线程的运行,while&(isThreadCheckRun)&...{&}那为什么要使用这个空循环等待timer的结束呢？原因是Timer类的运行基理，在C#下Timer触发的事件是不同于ＶＢ的，在.Net里无论Timer事件处理过程的执行时间是否超过它触发时间间隔在Timer里总会在指定时间被调用，也就是说如果触发间隔却是100毫秒，然而我们的处理过程用了500毫秒来运行代码。这样的话下一个事件的触发将在我们这个事件还没有结束时又进行了，如此一来起不是灾难的！
对于接下来我们还要等待可能存在的threadCreate线程结束，不过在等待它结束时先给他发送一个暂停信号，这个信号由createThreadProcessRun&变量传递进去。也许有人回问为什么不使用join来阻止threadCreate的运行，原因是这样的，假如threadCreate打算创建minConnection个连接，然而恰恰在创建到minConnection - n 个时候我停止也连接池，如果在这里使用join的话我们将不确定下次恢复运行时候究竟要创建多少个连接，最好的解决办法就是叫线程自己找一个安全的地方把自己join。
在下面的代码就是把每一个连接分别销毁掉并且在连接池中将它删除掉。有人说，那你只是删除了你内部的引用，的确我们只删除了内部的引用，因为销毁只是形式的销毁在.net上我们不能控制内存去销毁一个对象，只能叫GC帮忙来清理它。在程序段的最后我们使用私有的UpdateAttribute方法来更新属性字段。
&下面是Java版本的代码
&&&&/**&*//**
&&&&&*&停止服务，线程安全
&&&&&*&@throws&ResCallBackException&资源未全部回首
&&&&&*&@throws&PoolNotRunException&服务没有运行
&&&&public&void&StopServices()&throws&ResCallBackException,&PoolNotRunException&...{
&&&&&&&&StopServices(false);
&&&&/**&*//**
&&&&&*&停止服务，线程安全
&&&&&*&@param&needs&boolean&是否必须退出；如果指定为false与StartServices()功能相同，如果指定为true。将未收回的连接资源关闭，这将是危险的。认为可能你的程序正在使用此资源。
&&&&&*&@throws&ResCallBackException&服务未启动
&&&&&*&@throws&PoolNotRunException&服务没有运行
&&&&public&void&StopServices(boolean&needs)&throws&PoolNotRunException,&ResCallBackException&...{
&&&&&&&&synchronized&(this)&...{
&&&&&&&&&&&&if&(_PoolState&==&PoolState_Run)&...{
&&&&&&&&&&&&&&&&synchronized&(hs_UseConn)&...{
&&&&&&&&&&&&&&&&&&&&if&(needs&==&true)&//必须退出
&&&&&&&&&&&&&&&&&&&&&&&&hs_UseConn.clear();
&&&&&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&if&(hs_UseConn.size()&!=&<span style="color:#)
&&&&&&&&&&&&&&&&&&&&&&&&throw&new&ResCallBackException();&//连接池资源未全部回收
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&threadCheck.StopTimer();
&&&&&&&&&&&&&&&&while&(threadCreate.getState()!=Thread.State.WAITING)&...{&}//等待threadCreate事件结束
&&&&&&&&&&&&&&&&threadCreate.createThreadProcessRun&=&false;
&&&&&&&&&&&&&&&&while&(threadCreate.getState()&!=&Thread.State.WAITING)&...{}&//等待可能存在的创建线程结束
&&&&&&&&&&&&&&&&synchronized&(al_All)&...{
&&&&&&&&&&&&&&&&&&&&for&(int&i&=&<span style="color:#;&i&&&al_All.size();&i++)
&&&&&&&&&&&&&&&&&&&&&&&&((ConnStruct)&al_All.get(i)).Dispose();
&&&&&&&&&&&&&&&&&&&&al_All.clear();
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&_PoolState&=&PoolState_S
&&&&&&&&&&&&}&else
&&&&&&&&&&&&&&&&throw&new&PoolNotRunException();&//服务未启动
&&&&&&&&UpdateAttribute();&//更新属性
申请&GetConnectionFormPool
&&&&&&&&/**////&&summary&
&&&&&&&&///&在连接池中申请一个连接，使用None级别，线程安全
&&&&&&&&///&&/summary&
&&&&&&&&///&¶m&name=&gui&&发起者&/param&
&&&&&&&&///&&returns&返回申请到的连接&/returns&
&&&&&&&&public&DbConnection&GetConnectionFormPool(object&key)
&&&&&&&&...{&return&GetConnectionFormPool(key,&ConnLevel.None);&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&在连接池中申请一个连接，线程安全
&&&&&&&&///&&/summary&
&&&&&&&&///&¶m&name=&key&&申请者&/param&
&&&&&&&&///&¶m&name=&cl&&申请的连接级别&/param&
&&&&&&&&///&&returns&返回申请到的连接&/returns&
&&&&&&&&public&DbConnection&GetConnectionFormPool(object&key,&ConnLevel&cl)
&&&&&&&&...{
&&&&&&&&&&&&lock&(this)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&if&(_ps&!=&PoolState.Run)
&&&&&&&&&&&&&&&&&&&&throw&new&StateException();//服务状态错误
&&&&&&&&&&&&&&&&if&(hs_UseConn.Count&==&MaxConnectionFormPool)
&&&&&&&&&&&&&&&&&&&&throw&new&PoolFullException();//连接池已经饱和，不能提供连接
&&&&&&&&&&&&&&&&if&(hs_UseConn.ContainsKey(key))
&&&&&&&&&&&&&&&&&&&&throw&new&KeyExecption();//一个key对象只能申请一个连接
&&&&&&&&&&&&&&&&if&(cl&==&ConnLevel.ReadOnly)
&&&&&&&&&&&&&&&&&&&&return&GetConnectionFormPool_ReadOnly(key);//ReadOnly级别
&&&&&&&&&&&&&&&&else&if&(cl&==&ConnLevel.High)
&&&&&&&&&&&&&&&&&&&&return&GetConnectionFormPool_High(key);//High级别
&&&&&&&&&&&&&&&&else&if&(cl&==&ConnLevel.None)
&&&&&&&&&&&&&&&&&&&&return&GetConnectionFormPool_None(key);//None级别
&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&return&GetConnectionFormPool_Bottom(key);//Bottom级别
&&&&&&&&&&&&}
& &在向连接池申请一个连接资源时我们必须指定一个申请者，同时可以指定一个级别参数最后会根据不同的级别调用不同的策略，这些策略是在上面介绍过的4钟策略，下面不做过多的介绍。
（Java版本不在放出原因代码与C#完全相同）
下面将逐一放出４种策略的完整代码不做过多解释，其功能以在前文介绍过
&&&&&&&&/**////&&summary&
&&&&&&&&///&申请一个连接资源，只读方式，线程安全
&&&&&&&&///&&/summary&
&&&&&&&&///&¶m&name=&key&&申请者&/param&
&&&&&&&&///&&returns&申请到的连接对象&/returns&
&&&&&&&&protected&DbConnection&GetConnectionFormPool_ReadOnly(object&key)
&&&&&&&&...{
&&&&&&&&&&&&ConnStruct&cs&=&null;
&&&&&&&&&&&&for&(int&i&=&<span style="color:#;&i&&&al_All.C&i++)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&cs&=&(ConnStruct)al_All[i];
&&&&&&&&&&&&&&&&if&(cs.Enable&==&false&||&cs.Allot&==&false&||&cs.UseDegree&==&_maxRepeatDegree&||&cs.IsUse&==&true)
&&&&&&&&&&&&&&&&&&&&continue;
&&&&&&&&&&&&&&&&return&GetConnectionFormPool_Return(key,&cs,&ConnLevel.ReadOnly);&//返回得到的连接
&&&&&&&&&&&&}
&&&&&&&&&&&&return&GetConnectionFormPool_Return(key,&null,&ConnLevel.ReadOnly);
&&&&&&&&/**////&&summary&
&&&&&&&&///&申请一个连接资源，优先级-高，线程安全
&&&&&&&&///&&/summary&
&&&&&&&&///&¶m&name=&key&&申请者&/param&
&&&&&&&&///&&returns&申请到的连接对象&/returns&
&&&&&&&&protected&DbConnection&GetConnectionFormPool_High(object&key)
&&&&&&&&...{
&&&&&&&&&&&&ConnStruct&cs&=&null;
&&&&&&&&&&&&ConnStruct&csTemp&=&null;
&&&&&&&&&&&&for&(int&i&=&<span style="color:#;&i&&&al_All.C&i++)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&csTemp&=&(ConnStruct)al_All[i];
&&&&&&&&&&&&&&&&if&(csTemp.Enable&==&false&||&csTemp.Allot&==&false&||&csTemp.UseDegree&==&_maxRepeatDegree)//不可以分配跳出本次循环。
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&csTemp&=&null;
&&&&&&&&&&&&&&&&&&&&continue;
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&if&(csTemp.UseDegree&==&<span style="color:#)//得到最合适的
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&cs&=&csT
&&&&&&&&&&&&&&&&&&&&break;
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&else//不是最合适的放置到最佳选择中
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&if&(cs&!=&null)
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&if&(csTemp.UseDegree&&&cs.UseDegree)
&&&&&&&&&&&&&&&&&&&&&&&&&&&&//与上一个最佳选择选出一个最佳的放置到cs中
&&&&&&&&&&&&&&&&&&&&&&&&&&&&cs&=&csT
&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&&&&&cs&=&csT
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&}
&&&&&&&&&&&&return&GetConnectionFormPool_Return(key,&cs,&ConnLevel.High);//返回最合适的连接
&&&&&&&&/**////&&summary&
&&&&&&&&///&申请一个连接资源，优先级-中，线程安全
&&&&&&&&///&&/summary&
&&&&&&&&///&¶m&name=&key&&申请者&/param&
&&&&&&&&///&&returns&申请到的连接对象&/returns&
&&&&&&&&protected&DbConnection&GetConnectionFormPool_None(object&key)
&&&&&&&&...{
&&&&&&&&&&&&ArrayList&al&=&new&ArrayList();
&&&&&&&&&&&&ConnStruct&cs&=&null;
&&&&&&&&&&&&for&(int&i&=&<span style="color:#;&i&&&al_All.C&i++)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&cs&=&(ConnStruct)al_All[i];
&&&&&&&&&&&&&&&&if&(cs.Enable&==&false&||&cs.Allot&==&false&||&cs.UseDegree&==&_maxRepeatDegree)//不可以分配跳出本次循环。
&&&&&&&&&&&&&&&&&&&&continue;
&&&&&&&&&&&&&&&&if&(cs.Allot&==&true)
&&&&&&&&&&&&&&&&&&&&al.Add(cs);
&&&&&&&&&&&&}
&&&&&&&&&&&&if&(al.Count&==&<span style="color:#)
&&&&&&&&&&&&&&&&return&GetConnectionFormPool_Return(key,&null,&ConnLevel.None);//发出异常
&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&return&GetConnectionFormPool_Return(key,&((ConnStruct)al[al.Count&/&<span style="color:#]),&ConnLevel.None);//返回连接
&&&&&&&&/**////&&summary&
&&&&&&&&///&申请一个连接资源，优先级-低，线程安全
&&&&&&&&///&&/summary&
&&&&&&&&///&¶m&name=&key&&申请者&/param&
&&&&&&&&///&&returns&申请到的连接对象&/returns&
&&&&&&&&protected&DbConnection&GetConnectionFormPool_Bottom(object&key)
&&&&&&&&...{
&&&&&&&&&&&&ConnStruct&cs&=&null;
&&&&&&&&&&&&ConnStruct&csTemp&=&null;
&&&&&&&&&&&&for&(int&i&=&<span style="color:#;&i&&&al_All.C&i++)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&csTemp&=&(ConnStruct)al_All[i];
&&&&&&&&&&&&&&&&if&(csTemp.Enable&==&false&||&csTemp.Allot&==&false&||&csTemp.UseDegree&==&_maxRepeatDegree)//不可以分配跳出本次循环。
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&csTemp&=&null;
&&&&&&&&&&&&&&&&&&&&continue;
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&else//不是最合适的放置到最佳选择中
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&if&(cs&!=&null)
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&if&(csTemp.UseDegree&&&cs.UseDegree)
&&&&&&&&&&&&&&&&&&&&&&&&&&&&//与上一个最佳选择选出一个最佳的放置到cs中
&&&&&&&&&&&&&&&&&&&&&&&&&&&&cs&=&csT
&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&&&&&cs&=&csT
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&}
&&&&&&&&&&&&return&GetConnectionFormPool_Return(key,&cs,&ConnLevel.Bottom);//返回最合适的连接
Java版本不在放出原因代码与C#完全相同
&&在上面代码中所有策略都调用GetConnectionFormPool_Return方法。具体是什么呢？让我们来看看
&&&&&&&&/**////&&summary&
&&&&&&&&///&返回DbConnection对象，同时做获得连接时的必要操作
&&&&&&&&///&&/summary&
&&&&&&&&///&¶m&name=&key&&key&/param&
&&&&&&&&///&¶m&name=&cs&&ConnStruct对象&/param&
&&&&&&&&///&¶m&name=&cl&&级别&/param&
&&&&&&&&///&¶m&name=&readOnly&&是否为只读属性&/param&
&&&&&&&&///&&returns&&/returns&
&&&&&&&&private&DbConnection&GetConnectionFormPool_Return(object&key,&ConnStruct&cs,&ConnLevel&cl)
&&&&&&&&...{
&&&&&&&&&&&&try
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&if&(cs&==&null)
&&&&&&&&&&&&&&&&&&&&throw&new&Exception();
&&&&&&&&&&&&&&&&cs.Repeat();
&&&&&&&&&&&&&&&&hs_UseConn.Add(key,&cs);
&&&&&&&&&&&&&&&&if&(cl&==&ConnLevel.ReadOnly)
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&cs.Allot&=&false;
&&&&&&&&&&&&&&&&&&&&cs.IsRepeat&=&false;
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&}
&&&&&&&&&&&&catch&(Exception&e)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&throw&new&OccasionExecption();//连接资源耗尽，或错误的访问时机。
&&&&&&&&&&&&}
&&&&&&&&&&&&finally
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&UpdateAttribute();//更新属性
&&&&&&&&&&&&}
&&&&&&&&&&&&return&cs.C
该方法就是返回DbConnection对象，同时将获得的连接引用记数+1，在程序的第一行进行了一下内部错误判断如果是一个空的cs则抛出一个异常，该异常由方法体内接收并且将异常统一包装为OccasionExecption类型异常。hs_UseConn.Add(key,&cs);是将被申请到的连接资源注册到连接池。同时也确定这个被申请走的连接是不是以只读方式申请的，如果是则将这个连接锁定。
cs.Allot&=&false;//设置该连接不能再次被分配
&cs.IsRepeat&=&false;//设置连接不能使用引用记数技术
(Java版本不在放出原因代码与C#完全相同)
&释放DisposeConnection
&&&&&&&&/**////&&summary&
&&&&&&&&///&释放申请的数据库连接对象，线程安全
&&&&&&&&///&¶m&name=&key&&key表示数据库连接申请者&/param&
&&&&&&&&///&&/summary&
&&&&&&&&public&void&DisposeConnection(object&key)
&&&&&&&&...{
&&&&&&&&&&&&lock&(hs_UseConn)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&ConnStruct&cs&=&null;
&&&&&&&&&&&&&&&&if&(_ps&==&PoolState.Run)
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&if&(!hs_UseConn.ContainsKey(key))
&&&&&&&&&&&&&&&&&&&&&&&&throw&new&NotKeyExecption();//无法释放，不存在的key
&&&&&&&&&&&&&&&&&&&&cs&=&(ConnStruct)hs_UseConn[key];
&&&&&&&&&&&&&&&&&&&&cs.IsRepeat&=&true;
&&&&&&&&&&&&&&&&&&&&if&(cs.Allot&==&false)
&&&&&&&&&&&&&&&&&&&&&&&&if&(cs.Enable&==&true)
&&&&&&&&&&&&&&&&&&&&&&&&&&&&cs.Allot&=&true;
&&&&&&&&&&&&&&&&&&&&cs.Remove();
&&&&&&&&&&&&&&&&&&&&hs_UseConn.Remove(key);
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&throw&new&PoolNotRunException();//服务未启动
&&&&&&&&&&&&}
&&&&&&&&&&&&UpdateAttribute();//更新属性
&在释放资源中可以说是上面申请资源的反方向操作其中不同点在于
if&(cs.Enable&==&true)
cs.Allot&=&true;
这段话的意思是如果连接对象已经失效则不更改会不会再次被分配的属性如果仍然有效则更改为会再次被分配，因为被包装后的Connection不会自己知道自己是否已经超过引用记数所要求的最大上限。
(Java版本不在放出原因代码与C#完全相同)
如何更新属性
&&&&&&&&/**////&&summary&
&&&&&&&&///&更新属性
&&&&&&&&///&&/summary&
&&&&&&&&private&void&UpdateAttribute()
&&&&&&&&...{
&&&&&&&&&&&&int&temp_readOnlyFormPool&=&<span style="color:#;//连接池已经分配多少只读连接
&&&&&&&&&&&&int&temp_potentRealFormPool&=&<span style="color:#;//连接池中存在的实际连接数(有效的实际连接)
&&&&&&&&&&&&int&temp_spareRealFormPool&=&<span style="color:#;//空闲的实际连接
&&&&&&&&&&&&int&temp_useRealFormPool&=&<span style="color:#;//已分配的实际连接
&&&&&&&&&&&&int&temp_spareFormPool&=&MaxConnectionFormP//目前可以提供的连接数
&&&&&&&&&&&&//---------------------------------
&&&&&&&&&&&&lock&(hs_UseConn)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&_useFormPool&=&hs_UseConn.C
&&&&&&&&&&&&}
&&&&&&&&&&&&//---------------------------------
&&&&&&&&&&&&ConnStruct&cs&=&null;
&&&&&&&&&&&&int&n&=&<span style="color:#;
&&&&&&&&&&&&lock&(al_All)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&_realFormPool&=&al_All.C
&&&&&&&&&&&&&&&&for&(int&i&=&<span style="color:#;&i&&&al_All.C&i++)
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&cs&=&(ConnStruct)al_All[i];
&&&&&&&&&&&&&&&&&&&&//只读
&&&&&&&&&&&&&&&&&&&&if&(cs.Allot&==&false&&&&cs.IsUse&==&true&&&&cs.IsRepeat&==&false)
&&&&&&&&&&&&&&&&&&&&&&&&temp_readOnlyFormPool++;
&&&&&&&&&&&&&&&&&&&&//有效的实际连接
&&&&&&&&&&&&&&&&&&&&if&(cs.Enable&==&true)
&&&&&&&&&&&&&&&&&&&&&&&&temp_potentRealFormPool++;
&&&&&&&&&&&&&&&&&&&&//空闲的实际连接
&&&&&&&&&&&&&&&&&&&&if&(cs.Enable&==&true&&&&cs.IsUse&==&false)
&&&&&&&&&&&&&&&&&&&&&&&&temp_spareRealFormPool++;
&&&&&&&&&&&&&&&&&&&&//已分配的实际连接
&&&&&&&&&&&&&&&&&&&&if&(cs.IsUse&==&true)
&&&&&&&&&&&&&&&&&&&&&&&&temp_useRealFormPool++;
&&&&&&&&&&&&&&&&&&&&//目前可以提供的连接数
&&&&&&&&&&&&&&&&&&&&if&(cs.Allot&==&true)
&&&&&&&&&&&&&&&&&&&&&&&&temp_spareFormPool&=&temp_spareFormPool&-&cs.RepeatN
&&&&&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&&&&&temp_spareFormPool&=&temp_spareFormPool&-&_maxRepeatD
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&}
&&&&&&&&&&&&_readOnlyFormPool&=&temp_readOnlyFormP
&&&&&&&&&&&&_potentRealFormPool&=&temp_potentRealFormP
&&&&&&&&&&&&_spareRealFormPool&=&temp_spareRealFormP
&&&&&&&&&&&&_useRealFormPool&=&temp_useRealFormP
&&&&&&&&&&&&_spareFormPool&=&temp_spareFormP
在更新属性的方法里我们把每一个属性都做了一个对应的临时变量，为的就是防止在属性更新的时候被用户程序访问到属性更新期间的不准确信息，并且在连接池中所有属性更新操作都在此进行。
&如何确定连接是否失效
&&&&&&&&/**////&&summary&
&&&&&&&&///&测试ConnStruct是否过期
&&&&&&&&///&&/summary&
&&&&&&&&///&¶m&name=&cs&&被测试的ConnStruct&/param&
&&&&&&&&private&void&TestConnStruct(ConnStruct&cs)
&&&&&&&&...{
&&&&&&&&&&&&//此次被分配出去的连接是否在此次之后失效
&&&&&&&&&&&&if&(cs.UseDegree&==&_maxRepeatDegree)
&&&&&&&&&&&&&&&&cs.SetConnectionLost();//超过使用次数
&&&&&&&&&&&&if&(cs.CreateTime.AddMinutes(_exist).Ticks&&=&DateTime.Now.Ticks)
&&&&&&&&&&&&&&&&cs.SetConnectionLost();//连接超时
&&&&/**&*//**
&&&&&*&测试ConnStruct是否过期
&&&&&*&@param&cs&ConnStruct&被测试的ConnStruct
&&&&private&void&TestConnStruct(ConnStruct&cs)&...{
&&&&&&&&//此次被分配出去的连接是否在此次之后失效
&&&&&&&&if&(cs.GetUseDegree()&==&_MaxRepeatDegree)
&&&&&&&&&&&&cs.SetConnectionLost();&//超过使用次数
&&&&&&&&Calendar&c&=&Calendar.getInstance();
&&&&&&&&c.setTime(cs.GetCreateTime());
&&&&&&&&c.set(Calendar.MINUTE,&c.get(Calendar.MINUTE)&+&_Exist);
&&&&&&&&if&(c.getTime().after(new&Date()))
&&&&&&&&&&&&cs.SetConnectionLost();&//连接超时
使用线程管理连接池
threadCreate
& 前面已经很多次的提到threadCreate和threadCheck。那它们２究竟怎么运行的呢？还是先让我们看一看threadCreate。
&&&&&&&&/**////&&summary&
&&&&&&&&///&创建线程
&&&&&&&&///&&/summary&
&&&&&&&&private&void&createThreadProcess()
&&&&&&&&...{
&&&&&&&&&&&&bool&join&=&false;
&&&&&&&&&&&&int&createThreadProcessTemp_inside&=&createThreadProcessT
&&&&&&&&&&&&_ps&=&PoolState.I
&&&&&&&&&&&&while&(true)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&join&=&false;
&&&&&&&&&&&&&&&&_ps&=&PoolState.R
&&&&&&&&&&&&&&&&if&(createThreadProcessRun&==&false)
&&&&&&&&&&&&&&&&...{//遇到终止命令
&&&&&&&&&try&...{&threadCreate.Join();&}
&&&&&&&&&&&&&&&&&&&&catch&(Exception&e)&...{&}
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&if&(createThreadMode&==&<span style="color:#)
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&//------------------------begin&mode&&创建模式
&&&&&&&&&&&& ...............在下面中说明
&&&&&&&&&&&&&&&&&&&&&&&&//------------------------end&mode
&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&else&if&(createThreadMode&==&<span style="color:#)
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&//------------------------begin&mode&&增加模式
&&&&&&&&&&&& ...............在下面中说明
&&&&&&&&&&&&&&&&&&&&&&&&//------------------------end&mode
&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&&&&&join&=&true;
&&&&&&&&&&&&&&&&&&&&//-------------------------------------------------------------------------
&&&&&&&&&&&&&&&&&&&&if&(join&==&true)
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&UpdateAttribute();//更新属性
&&&&&&&&&&&&try
&&&&&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&&&&&createThreadProcessTemp&=&<span style="color:#;
&&&&&&&&&&&&&&&&&&&&&&&&&&&&threadCreate.Join();
&&&&&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&&&&&catch&(Exception&e)
&&&&&&&&&&&&&&&&&&&&&&&&...{&createThreadProcessTemp_inside&=&createThreadProcessT&}//得到传入的变量
&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&}
在线程中每次执行循环前都要判断自己是不是被要求终止，如果自己被要求终止则无条件将自己立即阻塞上，注意线程仅仅被阻塞没有被终止。
在下面一组createThreadMode&运行模式判断中如果出现不属于０或者１的模式则放出自己被阻止的信息。
在最后线程即将被阻止时将执行更新属性操作并且将自己的运行参数设置为０，因为当运行参数为０时即使线程被唤醒，它也将不会创建任何连接，最终自己还是被阻止。
模式０模式１
threadCheck
&&&&&&&&&&&&ConnStruct&cs&=&null;
&&&&&&&&&&&&time.Stop();//关闭自己
&&&&&&&&&&&&isThreadCheckRun&=&true;
&&&&&&&&&&&&//如果正在执行创建连接则退出
&&&&&&&&&&&&if&(threadCreate.ThreadState&!=&ThreadState.WaitSleepJoin)
&&&&&&&&&&&&&&&&return;
&&&&&&&&&&&&//------------------------------------------------------
&&&&&&&&&&&&lock&(al_All)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&int&n&=&<span style="color:#;
&&&&&&&&&&&&&&&&for&(int&i&=&<span style="color:#;&i&&&al_All.C&i++)
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&cs&=&(ConnStruct)al_All[i];
&&&&&&&&&&&&&&&&&&&&TestConnStruct(cs);//测试
&&&&&&&&&&&&&&&&&&&&if&(cs.Enable&==&false&&&&cs.RepeatNow&==&<span style="color:#)//没有引用的失效连接
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&cs.Close();//关闭它
&&&&&&&&&&&&&&&&&&&&&&&&al_All.Remove(cs);//删除
&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&}
&&&&&&&&&&&&//------------------------------------------------------
&&&&&&&&&&&&UpdateAttribute();//更新属性
&&&&&&&&&&&&if&(_spareRealFormPool&&&_keepRealConnection)//保留空闲实际连接数不足
&&&&&&&&&&&&&&&&createThreadProcessTemp&=&GetNumOf(_realFormPool,&_seepConnection,&_maxConnection);
&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&createThreadProcessTemp&=&<span style="color:#;
&&&&&&&&&&&&if&(createThreadProcessTemp&!=&<span style="color:#)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&//启动创建线程，工作模式1
&&&&&&&&&&&&&&&&createThreadMode&=&<span style="color:#;
&&&&&&&&&&&&&&&&threadCreate.Interrupt();
&&&&&&&&&&&&}
&&&&&&&&&&&&isThreadCheckRun&=&false;
&&&&&&&&&&&&time.Start();//打开自己
在C#中由于Timer拥有自己的特性，所以每次触发事件的时候都将自己关闭，以保证同时只有一个事件处理过程在运行，当处理结束时在将自己打开。
threadCheck线程的最主要目的就是测试当前所有实际连接是否有满足失效的连接，如果有失效的连接就将其设置为失效，同时清理已经没有任何引用的失效连接。在做完这些操作之后它还要得到是否要创建补充的连接如果需要创建补充的连接则在将这个数值传递给threadCreate并将之启动。
其中可能出现的问题就是，如果threadCreate已经启动我们在传递参数给它那可能会引发threadCreate的处理异常，因此在threadCheck过程中会首先判断threadCreate是否在阻止中如果不在阻止状态就return等待下次threadCheck的事件。
GetNumOf是为了得到应该创建的个数，代码实现如下
&&&&&&&&/**////&&summary&
&&&&&&&&///&得到当前要增加的量
&&&&&&&&///&&/summary&
&&&&&&&&private&int&GetNumOf(int&nowNum,&int&seepNum,&int&maxNum)
&&&&&&&&...{
&&&&&&&&&&&&if&(maxNum&&=&nowNum&+&seepNum)
&&&&&&&&&&&&&&&&return&seepN
&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&return&maxNum&-&nowN
下面是threadCheck的java版，因为前文说了在Java下没有Timer类有的Timer类还仅仅在AWT下工作，因此我们要先做一个Timer类，具体如下
&&&&/**&*//**
&&&&&*&&p&检测事件&/p&
&&&&private&class&CheckThreadProcess&extends&Thread&...{
&&&&&&&&private&long&_Interval&=&<span style="color:#0;&//执行间隔
&&&&&&&&private&boolean&timeSize=false;
&&&&&&&&/**&*//**
&&&&&&&&&*&启动记时器
&&&&&&&&&*/
&&&&&&&&public&void&StartTimer()
&&&&&&&&...{
&&&&&&&&&&&&timeSize=true;
&&&&&&&&&&&&if&(this.getState()==Thread.State.NEW)
&&&&&&&&&&&&&&&&this.start();
&&&&&&&&&&&&else&if&(this.getState()==Thread.State.WAITING)
&&&&&&&&&&&&&&&&this.interrupt();
&&&&&&&&/**&*//**
&&&&&&&&&*&停止记时器
&&&&&&&&&*/
&&&&&&&&public&void&StopTimer()
&&&&&&&&...{
&&&&&&&&&&&&timeSize=false;
&&&&&&&&&&&&while(this.getState()!=Thread.State.WAITING)...{&}
&&&&&&&&public&void&aRun()
&&&&&&&&...{
&&&&&&&&public&void&run()&...{
&&&&&&&&&&&&while&(true)&...{
&&&&&&&&&&&&&&&&try&...{
&&&&&&&&&&&&&&&&&&&&this.join(_Interval);
&&&&&&&&&&&&&&&&&&&&if&(timeSize&==&true)
&&&&&&&&&&&&&&&&&&&&&&&&aRun();
&&&&&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&&&&&this.join();
&&&&&&&&&&&&&&&&}&catch&(InterruptedException&ex1)&...{&}
&&&&&&&&&&&&}
&&&&&&&&/**&*//**
&&&&&&&&&*&设置执行时间间隔
&&&&&&&&&*&@param&value&double&时间间隔
&&&&&&&&&*/
&&&&&&&&public&void&setInterval(long&value)&...{
&&&&&&&&&&&&_Interval&=&
&&&&&&&&/**&*//**
&&&&&&&&&*&获得执行时间间隔
&&&&&&&&&*&@return&double&时间间隔
&&&&&&&&&*/
&&&&&&&&public&long&getInterval()&...{
&&&&&&&&&&&&return&_I
其中aRun方法就是threadCheck在C#下的处理过程代码如下
&&&&&&&&public&void&aRun()
&&&&&&&&...{
&&&&&&&&&&&&ConnStruct&cs&=&null;
&&&&&&&&&&&&//如果正在执行创建连接则退出
&&&&&&&&&&&&if&(threadCreate.getState()&!=&Thread.State.WAITING)
&&&&&&&&&&&&&&&&return;
&&&&&&&&&&&&//------------------------------------------------------
&&&&&&&&&&&&synchronized&(al_All)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&for&(int&i&=&<span style="color:#;&i&&&al_All.size();&i++)
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&cs&=&(ConnStruct)al_All.get(i);
&&&&&&&&&&&&&&&&&&&&TestConnStruct(cs);//测试
&&&&&&&&&&&&&&&&&&&&if&(cs.GetEnable()&==&false&&&&cs.GetRepeatNow()&==&<span style="color:#)//没有引用的失效连接
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&cs.Close();//关闭它
&&&&&&&&&&&&&&&&&&&&&&&&al_All.remove(cs);//删除
&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&}
&&&&&&&&&&&&//------------------------------------------------------
&&&&&&&&&&&&UpdateAttribute();//更新属性
&&&&&&&&&&&&if&(_SpareRealFormPool&&&_KeepRealConnection)//保留空闲实际连接数不足
&&&&&&&&&&&&&&&&threadCreate.createThreadProcessTemp&=&GetNumOf(_RealFormPool,&_SeepConnection,&_MaxConnection);
&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&threadCreate.createThreadProcessTemp&=&<span style="color:#;
&&&&&&&&&&&&//if&(threadCreate.createThreadProcessTemp&!=&0)
&&&&&&&&&&&&//{
&&&&&&&&&&&&//&&&&System.out.println(&创建&&+&threadCreate.createThreadProcessTemp);
&&&&&&&&&&&&//&&&&System.out.println(threadCreate.getState()+&&&this&&&+&this.getState());
&&&&&&&&&&&&//}
&&&&&&&&&&&&if&(threadCreate.createThreadProcessTemp&!=&<span style="color:#)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&//启动创建线程，工作模式1
&&&&&&&&&&&&&&&&threadCreate.createThreadMode&=&<span style="color:#;
&&&&&&&&&&&&&&&&threadCreate.interrupt();
&&&&&&&&&&&&}
至此一个拥有引用记数，集合线程管理的数据库连接池就完成了。下面是连接池的中被包装的连接代码
&&&&/**////&&summary&
&&&&///&连接池中的一个连接类型
&&&&///&&/summary&
&&&&public&class&ConnStruct&:&IDisposable
&&&&&&&&/**////&&summary&
&&&&&&&&///&连接池中的连接
&&&&&&&&///&&/summary&
&&&&&&&&///&¶m&name=&dbc&&数据库连接&/param&
&&&&&&&&///&¶m&name=&cte&&连接类型&/param&
&&&&&&&&public&ConnStruct(DbConnection&dbc,&ConnTypeEnum&cte)
&&&&&&&&...{
&&&&&&&&&&&&createTime&=&DateTime.N
&&&&&&&&&&&&connect&=&
&&&&&&&&&&&&connType&=&
&&&&&&&&/**////&&summary&
&&&&&&&&///&连接池中的连接
&&&&&&&&///&&/summary&
&&&&&&&&///&¶m&name=&dt&&连接创建时间&/param&
&&&&&&&&///&¶m&name=&dbc&&数据库连接&/param&
&&&&&&&&///&¶m&name=&cte&&连接类型&/param&
&&&&&&&&public&ConnStruct(DbConnection&dbc,&ConnTypeEnum&cte,&DateTime&dt)
&&&&&&&&...{
&&&&&&&&&&&&createTime&=&
&&&&&&&&&&&&connect&=&
&&&&&&&&&&&&connType&=&
&&&&&&&&//--------------------------------------------------------------------
&&&&&&&&private&bool&enable&=&true;//是否失效
&&&&&&&&private&bool&use&=&false;//是否正在被使用中
&&&&&&&&private&bool&allot&=&true;//表示该连接是否可以被分配
&&&&&&&&private&DateTime&createTime&=&DateTime.N//创建时间
&&&&&&&&private&int&useDegree&=&<span style="color:#;//被使用次数
&&&&&&&&private&int&repeatNow&=&<span style="color:#;//当前连接被重复引用多少
&&&&&&&&private&bool&isRepeat&=&true;//连接是否可以被重复引用，当被分配出去的连接可能使用事务时，该属性被标识为true
&&&&&&&&private&ConnTypeEnum&connType&=&ConnTypeEnum.N//连接类型
&&&&&&&&private&DbConnection&connect&=&null;//连接对象
&&&&&&&&private&object&obj&=&null;//连接附带的信息
&&&&&&&&属性部分#region&属性部分
&&&&&&&&/**////&&summary&
&&&&&&&&///&表示该连接是否可以被分配
&&&&&&&&///&&/summary&
&&&&&&&&public&bool&Allot
&&&&&&&&...{
&&&&&&&&&&&&get&...{&return&&}
&&&&&&&&&&&&set&...{&allot&=&&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&是否失效；false表示失效，只读
&&&&&&&&///&&/summary&
&&&&&&&&public&bool&Enable
&&&&&&&&...{&get&...{&return&&}&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&是否正在被使用中，只读
&&&&&&&&///&&/summary&
&&&&&&&&public&bool&IsUse
&&&&&&&&...{&get&...{&return&&}&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&创建时间，只读
&&&&&&&&///&&/summary&
&&&&&&&&public&DateTime&CreateTime
&&&&&&&&...{&get&...{&return&createT&}&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&被使用次数，只读
&&&&&&&&///&&/summary&
&&&&&&&&public&int&UseDegree
&&&&&&&&...{&get&...{&return&useD&}&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&当前连接被重复引用多少，只读
&&&&&&&&///&&/summary&
&&&&&&&&public&int&RepeatNow
&&&&&&&&...{&get&...{&return&repeatN&}&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&得到数据库连接状态，只读
&&&&&&&&///&&/summary&
&&&&&&&&public&ConnectionState&State
&&&&&&&&...{&get&...{&return&connect.S&}&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&得到该连接，只读
&&&&&&&&///&&/summary&
&&&&&&&&public&DbConnection&Connection
&&&&&&&&...{&get&...{&return&&}&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&连接是否可以被重复引用
&&&&&&&&///&&/summary&
&&&&&&&&public&bool&IsRepeat
&&&&&&&&...{
&&&&&&&&&&&&get&...{&return&isR&}
&&&&&&&&&&&&set&...{&isRepeat&=&&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&连接类型，只读
&&&&&&&&///&&/summary&&
&&&&&&&&public&ConnTypeEnum&ConnType
&&&&&&&&...{&get&...{&return&connT&}&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&连接附带的信息
&&&&&&&&///&&/summary&
&&&&&&&&public&object&Obj
&&&&&&&&...{
&&&&&&&&&&&&get&...{&return&&}
&&&&&&&&&&&&set&...{&obj&=&&}
&&&&&&&&#endregion
&&&&&&&&/**////&&summary&
&&&&&&&&///&打开数据库连接
&&&&&&&&///&&/summary&
&&&&&&&&public&void&Open()
&&&&&&&&...{&connect.Open();&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&关闭数据库连接&
&&&&&&&&///&&/summary&
&&&&&&&&public&void&Close()
&&&&&&&&...{&connect.Close();&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&无条件将连接设置为失效
&&&&&&&&///&&/summary&
&&&&&&&&public&void&SetConnectionLost()
&&&&&&&&...{&enable&=&false;&allot&=&false;&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&被分配出去，线程安全的
&&&&&&&&///&&/summary&
&&&&&&&&public&void&Repeat()
&&&&&&&&...{
&&&&&&&&&&&&lock&(this)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&if&(enable&==&false)//连接可用
&&&&&&&&&&&&&&&&&&&&throw&new&ResLostnExecption();//连接资源已经失效
&&&&&&&&&&&&&&&&if&(allot&==&false)//是否可以被分配
&&&&&&&&&&&&&&&&&&&&throw&new&AllotExecption();//连接资源不可以被分配
&&&&&&&&&&&&&&&&if&(use&==&true&&&&isRepeat&==&false)
&&&&&&&&&&&&&&&&&&&&throw&new&AllotAndRepeatExecption();//连接资源已经被分配并且不允许重复引用
&&&&&&&&&&&&&&&&repeatNow++;//引用记数+1
&&&&&&&&&&&&&&&&useDegree++;//被使用次数+1
&&&&&&&&&&&&&&&&use&=&true;//被使用
&&&&&&&&&&&&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&被释放回来，线程安全的
&&&&&&&&///&&/summary&
&&&&&&&&public&void&Remove()
&&&&&&&&...{
&&&&&&&&&&&&lock&(this)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&if&(enable&==&false)//连接可用
&&&&&&&&&&&&&&&&&&&&throw&new&ResLostnExecption();//连接资源已经失效
&&&&&&&&&&&&&&&&if&(repeatNow&==&<span style="color:#)
&&&&&&&&&&&&&&&&&&&&throw&new&RepeatIsZeroExecption();//引用记数已经为0
&&&&&&&&&&&&&&&&repeatNow--;//引用记数-1
&&&&&&&&&&&&&&&&if&(repeatNow&==&<span style="color:#)
&&&&&&&&&&&&&&&&&&&&use&=&false;//未使用
&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&use&=&true;//使用中
&&&&&&&&&&&&}
&&&&&&&&/**////&&summary&
&&&&&&&&///&释放资源
&&&&&&&&///&&/summary&
&&&&&&&&public&void&Dispose()
&&&&&&&&...{
&&&&&&&&&&&&enable&=&false;
&&&&&&&&&&&&connect.Close();
&&&&&&&&&&&&connect&=&null;
上面代码的Java实现
///&&summary&
///&连接池中的一个连接类型
///&&/summary&
public&class&ConnStruct&...{
&&&&private&boolean&_enable&=&true;&//是否失效
&&&&private&boolean&_isUse&=&false;&//是否正在被使用中
&&&&private&boolean&_allot&=&true;&//表示该连接是否可以被分配
&&&&private&Date&_createT&//创建时间
&&&&private&int&_useDegree&=&<span style="color:#;&//被使用次数
&&&&private&int&_repeatNow&=&<span style="color:#;&//当前连接被重复引用多少
&&&&private&boolean&_isRepeat&=&true;&//连接是否可以被重复引用，当被分配出去的连接可能使用事务时，该属性被标识为true
&&&&private&int&_connT&//连接类型
&&&&private&Connection&_connect&=&null;&//连接对象
&&&&/**&*//**
&&&&&*&连接池中的连接
&&&&&*&@param&dbc&Connection&数据库连接
&&&&public&ConnStruct(Connection&dbc)&...{
&&&&&&&&InitConnStruct(dbc,&new&Date());
&&&&/**&*//**
&&&&&*&连接池中的连接
&&&&&*&@param&dbc&Connection&&数据库连接
&&&&&*&@param&dt&Date&连接创建时间
&&&&public&ConnStruct(Connection&dbc,&Date&dt)&...{
&&&&&&&&InitConnStruct(dbc,&dt);
&&&&/**&*//**
&&&&&*&连接池中的连接
&&&&&*&@param&dbc&Connection&&数据库连接
&&&&&*&@param&dt&Date&连接创建时间
&&&&private&void&InitConnStruct(Connection&dbc,&Date&dt)&...{
&&&&&&&&_createTime&=&
&&&&&&&&_connect&=&
&&&&//--------------------------------------------------------------------
&&&&/**&*//**
&&&&&*&得到一个值表示该连接是否可以被分配
&&&&&*&@return&boolean&该连接是否可以被分配
&&&&public&boolean&GetAllot()&...{
&&&&&&&&return&_
&&&&/**&*//**
&&&&&*&设置一个值表示该连接是否可以被分配
&&&&&*&@param&value&boolean&true可以被分配，false不可以被分配
&&&&public&void&SetAllot(boolean&value)&...{
&&&&&&&&_allot&=&
&&&&/**&*//**
&&&&&*&得到当前连接是否失效
&&&&&*&@return&boolean&得到当前连接是否失效；false表示失效，只读
&&&&public&boolean&GetEnable()&...{
&&&&&&&&return&_
&&&&/**&*//**
&&&&&*&得到当前连接是否正在被使用中，只读
&&&&&*&@return&boolean&当前连接是否正在被使用中
&&&&public&boolean&GetIsUse()&...{
&&&&&&&&return&_isU
&&&&/**&*//**
&&&&&*&得到连接创建时间，只读
&&&&&*&@return&Date&创建时间
&&&&public&Date&GetCreateTime()&...{
&&&&&&&&return&_createT
&&&&/**&*//**
&&&&&*&得到被使用次数，只读
&&&&&*&@return&int&得到被使用次数
&&&&public&int&GetUseDegree()&...{
&&&&&&&&return&_useD
&&&&/**&*//**
&&&&&*&得到当前连接被重复引用多少，只读
&&&&&*&@return&int&当前连接被重复引用多少
&&&&public&int&GetRepeatNow()&...{
&&&&&&&&return&_repeatN
&&&&/**&*//**
&&&&&*&得到该连接，只读
&&&&&*&@return&Connection&连接
&&&&public&Connection&GetConnection()&...{
&&&&&&&&return&_
&&&&/**&*//**
&&&&&*&得到连接是否可以被重复引用
&&&&&*&@return&boolean&是否可以被重复引用
&&&&public&boolean&GetIsRepeat()&...{
&&&&&&&&return&_isR
&&&&/**&*//**
&&&&&*&设置连接是否可以被重复引用
&&&&&*&@param&value&boolean&true可以被重复引用，false不可以被重复引用
&&&&public&void&SetIsRepeat(boolean&value)&...{
&&&&&&&&_isRepeat&=&
&&&&/**&*//**
&&&&&*&得到连接类型ConnectionPool.ConnType_*，只读
&&&&&*&@return&int&连接类型
&&&&public&int&GetConnType()&...{
&&&&&&&&return&_connT
&&&&/**&*//**
&&&&&*&关闭数据库连接
&&&&public&void&Close()&...{
&&&&&&&&try&...{
&&&&&&&&&&&&_connect.close();
&&&&&&&&}&catch&(Exception&e)&...{}
&&&&/**&*//**
&&&&&*&无条件将连接设置为失效
&&&&public&void&SetConnectionLost()&...{
&&&&&&&&_enable&=&false;
&&&&&&&&_allot&=&false;
&&&&/**&*//**
&&&&&*&被分配出去，线程安全的
&&&&&*&@throws&ResLostnExecption
&&&&&*&@throws&AllotExecption
&&&&&*&@throws&AllotAndRepeatExecption
&&&&public&synchronized&void&Repeat()&throws&ResLostnException,&AllotException,
&&&&&&&&&&&&AllotAndRepeatException&...{
&&&&&&&&if&(_enable&==&false)&//连接可用
&&&&&&&&&&&&throw&new&ResLostnException();&//连接资源已经失效
&&&&&&&&if&(_allot&==&false)&//是否可以被分配
&&&&&&&&&&&&throw&new&AllotException();&//连接资源不可以被分配
&&&&&&&&if&(_isUse&==&true&&&&_isRepeat&==&false)
&&&&&&&&&&&&throw&new&AllotAndRepeatException();&//连接资源已经被分配并且不允许重复引用
&&&&&&&&_repeatNow++;&//引用记数+1
&&&&&&&&_useDegree++;&//被使用次数+1
&&&&&&&&_isUse&=&true;&//被使用
&&&&/**&*//**
&&&&&*&被释放回来，线程安全的
&&&&&*&@throws&ResLostnExecption&连接资源已经失效
&&&&&*&@throws&RepeatIsZeroExecption&引用记数已经为0
&&&&public&synchronized&void&Remove()&throws&ResLostnException,
&&&&&&&&&&&&RepeatIsZeroException&...{
&&&&&&&&if&(_enable&==&false)&//连接可用
&&&&&&&&&&&&throw&new&ResLostnException();&//连接资源已经失效
&&&&&&&&if&(_repeatNow&==&<span style="color:#)
&&&&&&&&&&&&throw&new&RepeatIsZeroException();&//引用记数已经为0
&&&&&&&&_repeatNow--;&//引用记数-1
&&&&&&&&if&(_repeatNow&==&<span style="color:#)
&&&&&&&&&&&&_isUse&=&false;&//未使用
&&&&&&&&else
&&&&&&&&&&&&_isUse&=&true;&//使用中
&&&&///&&summary&
&&&&///&释放资源
&&&&///&&/summary&
&&&&public&void&Dispose()&...{
&&&&&&&&_enable&=&false;
&&&&&&&&try&...{
&&&&&&&&&&&&_connect.close();
&&&&&&&&}&catch&(Exception&e)&...{}
&&&&&&&&_connect&=&null;
lock&(al_All)
if&(al_All.Count&&&createThreadProcessTemp_inside)
al_All.Add(CreateConnection(_connString,&_connType));
join&=&true;
在模式０中线程将一直创建连接，直到被创建的连接达到最小连接数目，具体实现方法是将最小要创建的连接存入al_All，直到al_All的元素个数达到最小连接数才放出自己被阻止的消息。
lock&(al_All)
if&(createThreadProcessTemp_inside&!=&<span style="color:#)
createThreadProcessTemp_inside--;
al_All.Add(CreateConnection(_connString,&_connType));
join&=&true;
在模式１中线程将一直创建连接，直到被创建的连接达到被要求的连接数目，具体实现方法是将最小要创建的连接存入createThreadProcessTemp_inside临时变量，然后每次创建一个连接就自减１直至到０时放出自己被阻止的消息。
以下是java的代码实现
&&&&/**&*//**
&&&&&*&&p&创建线程类&/p&
&&&&private&class&CreateThreadProcess&extends&Thread&...{
&&&&&&&&public&int&createThreadMode&=&<span style="color:#;&//创建线程工作模式
&&&&&&&&public&int&createThreadProcessTemp&=&<span style="color:#;&//需要创建的连接数
&&&&&&&&public&boolean&createThreadProcessRun&=&false;&//是否决定创建线程将继续工作，如果不继续工作则线程会将自己处于阻止状态
&&&&&&&&public&void&run()&...{
&&&&&&&&&&&&boolean&join&=&false;
&&&&&&&&&&&&int&createThreadProcessTemp_inside&=&createThreadProcessT
&&&&&&&&&&&&_PoolState&=&PoolState_I
&&&&&&&&&&&&while&(true)
&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&join&=&false;
&&&&&&&&&&&&&&&&_PoolState&=&PoolState_R
&&&&&&&&&&&&&&&&if&(createThreadProcessRun&==&false)
&&&&&&&&&&&&&&&&...{//遇到终止命令
&&&&&&&&&&&&&&&&&&&&try&...{
&&&&&&&&&&&&&&&&&&&&&&&&this.join();//中断自己
&&&&&&&&&&&&&&&&&&&&}&catch&(Exception&e)&...{/**//*&*/}
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&if&(createThreadMode&==&<span style="color:#)
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&//------------------------begin&mode&&创建模式
&&&&&&&&&&&&&&&&&&&&&&&&synchronized&(al_All)
&&&&&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&&&&&if&(al_All.size()&&&createThreadProcessTemp_inside)
&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&al_All.add(CreateConnectionTemp(_ConnString,_DriveString,_userID,_password));
&&&&&&&&&&&&&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&join&=&true;
&&&&&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&&&&&//------------------------end&mode
&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&else&if&(createThreadMode&==&<span style="color:#)
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&//------------------------begin&mode&&增加模式
&&&&&&&&&&&&&&&&&&&&&&&&synchronized&(al_All)
&&&&&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&&&&&if&(createThreadProcessTemp_inside&!=&<span style="color:#)
&&&&&&&&&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&createThreadProcessTemp_inside--;
&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&al_All.add(CreateConnectionTemp(_ConnString,_DriveString,_userID,_password));
&&&&&&&&&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&join&=&true;
&&&&&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&&&&&//------------------------end&mode
&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&&&&&else
&&&&&&&&&&&&&&&&&&&&&&&&join&=&true;
&&&&&&&&&&&&&&&&&&&&//-------------------------------------------------------------------------
&&&&&&&&&&&&&&&&&&&&if&(join&==&true)
&&&&&&&&&&&&&&&&&&&&...{
&&&&&&&&&&&&&&&&&&&&&&&&UpdateAttribute();//更新属性
&&&&&&&&&&&&&&&&&&&&&&&&try&...{
&&&&&&&&&&&&&&&&&&&&&&&&&&&&createThreadProcessTemp&=&<span style="color:#;
&&&&&&&&&&&&&&&&&&&&&&&&&&&&this.join();&//中断自己
&&&&&&&&&&&&&&&&&&&&&&&&}&catch&(Exception&e)&...{
&&&&&&&&&&&&&&&&&&&&&&&&&&&&createThreadProcessTemp_inside&=&createThreadProcessT
&&&&&&&&&&&&&&&&&&&&&&&&}&//得到传入的变量
&&&&&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&&&&&}
&&&&&&&&&&&&}
文章主要讨论了如何编写一个高效的数据库连接池，包括多种数据库的支持引用记数的应用，截止文章发表为止，该连接池已经发现潜在问题诸多，比如在长时间运行中threadCheck和threadCreate线程的运行可能会不稳定，那导致的问题是致命的，关于解决问题么可能还要加入线程池？或者在启动停止服务时候创建销毁它们？如果你有更好的办法请发表评论。以便于我继续改进。
另一个以发现的问题就是连接池没有对数据库连接状态做跟踪，这个对于我是失败的问题，在设计它时直到日发布之前都没有考虑到这个因素，郁闷
另外我想说的就是这个小东西虽然不是很多代码，但是菜鸟的我也弄了２个来月所以请转贴时注明出处和作者。
还有一点想说的是即使把代码放上来也不见得是极其完整的代码，如果有想要原代码的朋友请发邮件到我的邮箱，邮箱下面有写。
作者:赵永春
此处为日更新说明:本文所讲连接池有所升级,具体请参看
日追加更新 SVN地址，在使用SVN时可能需要你输入帐号密码，请在svnhost中注册一个帐号在下载源码。
java版本源码下载：
.net版本源码下载：
参考文献：《基于JDBC的数据库连接池高效管理策略》来源网络。
* 以上用户言论只代表其个人观点，不代表CSDN网站的观点或立场
访问：110150次
积分：1515
积分：1515
排名：第11217名
原创：21篇
转载：116篇
评论：39条
(1)(3)(1)(2)(3)(6)(3)(1)(16)(3)(3)(1)(6)(8)(8)(5)(14)(3)(3)(1)(22)(14)(6)(1)(1)(5)(4)(5)(2)(4)(1)}
我要回帖
更多关于 win7 连接数 的文章
更多推荐
- ·word中word页眉页脚怎么设置在尾注中输入方括号？
- ·请求大神，下图片道题log怎么求导做，碰到题中有对数㏒，以2为底x的对数，不知log怎么求导导。
- ·埃博拉病毒中国有过吗为什么发生在非洲 埃博拉病毒中国有过吗在中国发生过吗
- ·请问EXCEL表格计算工资如果大于1000，奖励表格图片100，大于1200奖励表格图片200，大于1400奖励表格图片300，要怎么套公式？
- ·RNA是生命起源于rna的主要依据的起源，为什么是由DNA转录而成？
- ·孙尚香主 忠内貂蝉大乔小乔谁演的甄姬 大家有什么要说的吗？
- ·求 天龙八部 百宝箱天龙自动打怪脚本本 详细点 怎么用 都发到发...
- ·为什么升级置顶98楼 后变得很卡?求优化大师升级方法
- ·求几个能作为《杀戮空间怎么联机》视频的好听的，激情的背景...
- ·仙境传说 95级刀流氓是怎么样练成的去哪练？！！！迷茫啊！！没...
- ·2011年4月有那些公司要北京订做工作服服的
- ·拳皇2002超必杀中选完K9999后，如何按出在半空中放必杀...
- ·求热心的动境兄国光帮帮忙2011解决问题，谢谢！
- ·5000块能投资什么一下的电脑，要能玩所有游戏的
- ·失眠的偏方治失眠
- ·qq炫舞升级奖励如何升级qq炫舞升级奖励商城道具qq炫舞升级奖励被封解除qq炫舞升级奖励飞行...
- ·你有各种经典游戏的卡农钢琴五线谱谱是吗？ 能发给我吗？
- ·谁有黑鹰坠落下载 字幕 只要字幕 用来学英语的
- ·QQqq西游传送点文件的时候，qq西游传送点多了，为什么会有限制？
- ·你还能把那超级玛丽传给我啊！我的邮箱是452013424@http freeqq2.qq.coo...
- ·如何设定每个帐号同一时间内允许的win7 连接数数?
- ·星辰变推荐人账号体验账号,只是体验下。谁能给个玩下。不改密码。
- ·有没有一款东西是用上去之后可以完美眼部遮瑕膏，美白...
- ·怎么样清除人人游戏同步助手怎么样里面游戏账号记录
- ·求一篇“学学习党史的心得体会、当先锋、谈体会”的文章
- ·寻找能解封魔兽世界账号解封的人！
- ·求日本BL、bl耽美小说游戏汉化版下载，请发送到1324472643@qq.c...
- ·教你sf如何sf solo命令完虐神灵
- ·广西贺州香港哪里买iphone4s苗
- ·WII主手机变砖砖如何修,用WASABI DX或是用DRIVEKEY,请赐教.
- ·e8ktv桌面互动游戏戏、专业ktv桌面游戏
- ·我想知道dnf51礼包首饰光之恩赐黄金手镯的满属性？有哪位大神...
- ·魔神战纪精灵加点刺客技能怎么加点啊
- ·2011年转会的球员能安装到2010实况足球2010转会吗？
- ·神魔大陆学徒礼包激爽礼包
- ·哪位知道google android sdk可以使用手机在线阅读软...
