Досрочно завершим!

watcom vs gcc

2009-06-29T05:57:00.005+10:00

Для удовлетворения любопытства, скачал openwatcom 1.8 (такой бывший когда то известным компилятор c/c++), исходники под линукс. собрал, и попробовал тестовую задачку, вот эту вот: http://shootout.alioth.debian.org/u32q/benchmark.php?test=binarytrees&lang=gcc&box=1

Резуьтаты:
GCC

walrus@home:/home/walrus/sandbox$ gcc btr.c -O3 -o btr_gcc -lm
walrus@home:/home/walrus/sandbox$ time ./btr_gcc 20
stretch tree of depth 21 check: -1
2097152 trees of depth 4 check: -2097152
524288 trees of depth 6 check: -524288
131072 trees of depth 8 check: -131072
32768 trees of depth 10 check: -32768
8192 trees of depth 12 check: -8192
2048 trees of depth 14 check: -2048
512 trees of depth 16 check: -512
128 trees of depth 18 check: -128
32 trees of depth 20 check: -32
long lived tree of depth 20 check: -1

real 1m2.138s
user 1m1.852s
sys 0m0.120s

watcom

walrus@home:/home/walrus/sandbox$ PATH=$PATH:/opt/watcom/binl WATCOM=/opt/watcom owcc -I/opt/watcom/h -O3 -obtr_wc btr.c
walrus@home:/home/walrus/sandbox$ time ./btr_wc 20
stretch tree of depth 21 check: -1
2097152 trees of depth 4 check: -2097152
524288 trees of depth 6 check: -524288
131072 trees of depth 8 check: -131072
32768 trees of depth 10 check: -32768
8192 trees of depth 12 check: -8192
2048 trees of depth 14 check: -2048
512 trees of depth 16 check: -512
128 trees of depth 18 check: -128
32 trees of depth 20 check: -32
long lived tree of depth 20 check: -1

real 0m47.934s
user 0m47.675s
sys 0m0.136s

62 секунды против 48 в пользу watcom-а. Ай да старик watcom!! Вот это да!

UPD Да, забыл - ubuntu 9.04 32 AMD, 4000+, gcc gcc версия 4.3.3 (Ubuntu 4.3.3-5ubuntu4), watcom :

owcc -v
Open Watcom C/C++32 Compiler Driver Program Version 1.8beta1 LA
Portions Copyright (c) 1988-2002 Sybase, Inc. All Rights Reserved.
Source code is available under the Sybase Open Watcom Public License.
See http://www.openwatcom.org/ for details.

couchdb benchmark еще раз

2008-09-05T00:18:00.003+10:00

Попробоавл тот же тест, но 10 процессов по 10000 записей. Суммарные цифры - 100_000 записей за 2308 сек. То есть 43 записи/сек. Примерно так же как и в прошлом тесте. Похоже, быстрее уде не разогнать.

Размер базы при 100000 записях - 0.6G

couchdb benchmark II

2008-09-05T00:10:00.004+10:00

Однако не все так плохо..

Если запустить 50 программ, каждая из которых пытается вставить по 200 записей (те же 10000 записей, что и в прошлом тесте), то вставка всех записей укладывается в 220 сек. Значит - суммарно скорость вставки при 50 процессах - 45 записей в секунду.

Кстати - база couchdb с 10000 записями (структура в предыдущем сообшении блога) занимает 54.3M.

На компьютере Intel 3.2GHz, RAM 1G, ubuntu 8.04

couchdb benchmark

2008-09-04T22:53:00.007+10:00

Захотелось попробовать новую couchdb. Выглядит она хорошо, и все сделано удобно. Однако прежде чем ее использовать в каком-нибудь проекте, хотелось бы оценит ее возможности более точно.

Прежде всего посмотрим скорострельность.
Для этого напишем мелкую программу на питоне, которая вставляет ну.. 10000 записей. и пусть пишет сколько секунд прошло с начала теста.


from couchdb import Server
import time

server = Server('http://localhost:5984/')
del server['benchmark']

db = server.create('benchmark')
benchstart = int(time.time())
print "Begin test %s"%benchstart
for i in range(1,10000):
    doc_id = db.create({'type': 'BenchRecord', 'intfld': i, 'charfld': 'SomeName%s'%i })
    if i % 100 == 0:
#        print "%s :: %s "%(datetime.datetime.today(),i)
         bench_offset = int(time.time()) - benchstart
         print "%d\t%d "%(bench_offset,i)

print "End test, %d sec"%(int(time.time()) - benchstart)
del server['benchmark']

Запускаем - получили в результате:

Begin test 1220531930
6 100
11 200
17 300
23 400
29 500
35 600
40 700
46 800
52 900
58 1000
64 1100
70 1200
76 1300
82 1400
87 1500
93 1600
99 1700
105 1800
111 1900
117 2000
123 2100
129 2200
135 2300
140 2400
146 2500
152 2600
158 2700
164 2800
170 2900
176 3000
182 3100
188 3200
194 3300
200 3400
206 3500
212 3600
218 3700
224 3800
229 3900
235 4000
241 4100
247 4200
254 4300
260 4400
266 4500
272 4600
278 4700
284 4800
290 4900
296 5000
302 5100
309 5200
315 5300
321 5400
327 5500
333 5600
339 5700
345 5800
351 5900
357 6000
363 6100
369 6200
376 6300
382 6400
388 6500
394 6600
400 6700
406 6800
412 6900
418 7000
424 7100
430 7200
436 7300
442 7400
448 7500
454 7600
460 7700
466 7800
472 7900
478 8000
484 8100
490 8200
496 8300
502 8400
508 8500
514 8600
520 8700
526 8800
532 8900
538 9000
544 9100
550 9200
556 9300
562 9400
568 9500
574 9600
580 9700
587 9800
593 9900
End test, 599 sec

Отсюда мораль.

1)Вставка 100 записей за (в среднем) 6 секунд. Немного. 16 записей/сек

2)достаточно линейно , в диапазоне до 10000 записей.

2008-08-16T23:43:00.001+10:00

MyHeritage: Генеалогические деревья - Генеалогия - Знаменитости

Марк Твен

2008-06-22T05:26:00.005+10:00

"Если вам понадобится подвергнуть молодого человека тяжелому и мучительному наказанию, возьмите с него слово, что он в течение года будет вести дневник."

erlang & postgresql auth

2008-06-06T01:11:00.009+10:00

Для прямого доступа из эрланга в postgresql (минуя odbc) есть хорошая библиотечка, написанная Martin Carlsson из Erlang Training & Consulting ltd (Здесь).
У нее есть один недостаток - она рассчитана только на md5 authentication в постгресе.

Если приложение разрабатывается с нуля, то md5 auth - не представляет проблемы, как захотим, так и настроим, но в нашем случае уже есть большой и толстый postgresql сервер, со своими админами и правилами выделения учетных записей. В этом сервере метод доступа у большинства аккаунтов - password. И никак это не поправишь. В отличие от технических проблем - административные проблемы плохо поддаются решению..

Пришлось прочитать хорошенько документацию postgresql, раздел где описан протокол, и поправить erlang-овскую библиотеку. Вот, чтобы не забыть, что я там наисправлял, и выкладываю diff


diff -Naur oldsrc/psql_logic.erl src/psql_logic.erl
--- oldsrc/psql_logic.erl       2006-09-18 17:46:20.000000000 +0200
+++ src/psql_logic.erl  2008-03-12 17:41:48.000000000 +0100
@@ -139,6 +139,12 @@
     AuthDigest = psql_protocol:md5digest(State#state.digest, Salt),
     psql_connection:command(State#state.connection, {send, AuthDigest}),
     {next_state, authentication, State};
+
+authentication({psql, authentication, <<0,0,0,3>>}, State) ->
+    CTPassw = psql_protocol:ctpasswd(State#state.password),
+    psql_connection:command(State#state.connection, {send, CTPassw}),
+    {next_state, authentication, State};
+
 authentication({psql, authentication, <<0,0,0,0>>}, State) ->
     {next_state, setup, State};
 authentication({psql, error, Error}, State) ->
diff -Naur oldsrc/psql_protocol.erl src/psql_protocol.erl
--- oldsrc/psql_protocol.erl    2006-09-18 17:46:24.000000000 +0200
+++ src/psql_protocol.erl       2008-03-12 17:41:31.000000000 +0100
@@ -21,7 +21,7 @@
         to_string/1]).
 
 -export([authenticate/4,
-        md5digest/2,
+        md5digest/2,ctpasswd/1,
         copy_done/0,
         q/1]).
 
@@ -65,6 +65,9 @@
     Auth = md5([Digest, Salt]),
     {password_message, <<"md5", Auth/binary, 0:8>>}.
 
+ctpasswd(Passw) ->
+    PB = list_to_binary(Passw),
+    {password_message, << PB/binary,0:8 >>}.
+
 copy_done() ->
     {'copy_done', []}.

erlang snmp client

2008-03-11T23:21:00.008+10:00

Вот понадобилось опрашивать некоторые железные switch через snmp из erlang. Первая попытка понять что для этого нужна (наскоком, по Буденновски) - не удалась. на erlang.org полно документации как писать и управлять snmp сервера, но вот информация по клиентам - разбросана по крупицам. Так что пришлось собраться и создать картину у себя в голове, как должен выглядить snmp клиент.

Общая картина

Общая идея такая. Нет одной такой командочки типа snmpwalk. Мы вынуждены строить целую систему для того чтобы опросить железку.

Есть snmp manager, мы его должны настроить и запустить, даже если у нас только клиент. Этот snmp manager содержит список snmp user. Я сначала думал что snmp user - это что-то типа community, оказалось - нет.. Snmp user в erlang - это такой модуль, который содержит просто набор callback для приема ответов от устройств.

Manager должен либо определять этого user-а в свой конфигурации, либо зарегистрировать его с помощью snmpm:register_user(имя, модуль).

Дальше нам нужны agents. То есть manager каждому такому user назначает (в конфиге, либо с помощью snmpm:register_agent ) набор агентов которых опрашивать. Вот эти агенты как раз и содержат реквизиты опрашиваемых железок. Там, IP, community, port, версию протокола и т.д.

Когда все это настроено, можно посылать из manager-а запрос. Например с помощью snmpm:ag(). Manager поищет в настройках который это агент(по адресу). Пошлет асинхронный запрос на железку, а когда придет ответ, Manager по привязанным user/agent, сообразит на которого user (ну грубо говоря в какой модуль) его переслать.

В данном случает придет ответ на handle_pdu(Addr, Port, ReqId, SnmpResponse, UserData) в том user-е к которому привязан агент, куда посылался запрос.

В следующих постах приведу примеры кода.

Performance degradation for gcc

2008-02-29T03:04:00.003+10:00

Просмативая свои старые архивы, нашел мелкую программу sieve- решето Эратосфена, которая была написана на разных языках. И там же валялся бинарник этой программы, скомпилированной gcc в далеком (по моему 2002) году. Запустил из интереса - получилось

103763 iterations in 10.000000 seconds.

Скомпилировал текущей версией gcc из ubuntu - получилось
96992 iterations in 10.000000 seconds

Вот тебе бабушка и Юрьев день!

Какой был в 2002 gcc не помню, file a.out покзывает

a.out: ELF 32-bit LSB executable, Intel 80386, version 1 (SYSV), for GNU/Linux 2.0.0, dynamically linked (uses shared libs), not stripped

Теперь у нас gcc version 4.1.3 20070929 (prerelease) (Ubuntu 4.1.2-16ubuntu2), file показывает
a.out: ELF 32-bit LSB executable, Intel 80386, version 1 (SYSV), for GNU/Linux 2.6.8, dynamically linked (uses shared libs), not stripped

То есть все честно.. Но медленнее..

Этот удивительный erlang - (sinan)

2008-02-28T23:32:00.006+10:00

Решил для erlang попробовать sinan - систему построения application и релизов.. Вот такое он мне выдал сообщение при опечатке в конфигурационном файле:
{error_logger, {{2008, 2, 28}, {14, 27, 26}}, "** Generic server ~p terminating \n** Last message in was ~p~n** When Server state == ~p~n** Reason for termination == ~n** ~p~n", [<0.70.0>, {parse, "/home/walrus/erlang_1/_build.cfg"}, {state, #Fun, {dict, 9, 16, 16, 8, 80, 48, {[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}, {{[], [], [], [], [], [["build_dir", 95, 98, 117, 105, 108, 100], ["default_flavor", 100, 101, 118, 101, 108, 111, 112, 109, 101, 110, 116], ["tasks"|{dict, 12, 16, 16, 8, 80, 48, {[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}, {{[], [], [], [["dist"|{dict, 3, 16, 16, 8, 80, 48, {[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}, {{[], [], [], [], [], [], [["depends", "release"]], [], [], [], [], [["description", "Creates an tarball of the distribution including ", "release information. Check documentation for the ", "dist task for configuration information "]], [], [["handler", 115, 105, 110, 95, 100, 105, 115, 116, 95, 98, 117, 105, 108, 100, 101, 114]], [], []}}}]], [["release"|{dict, 3, 16, 16, 8, 80, 48, {[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}, {{[], [], [], [], [], [], [["depends", "build"]], [], [], [], [], [["description", "Creates the *.rel, *.boot and *.script into the ", "/realeases/ directory. It also ", "builds up a release tar bal into the ", "/tar/ directory"]], [], [["handler", 115, 105, 110, 95, 114, 101, 108, 101, 97, 115, 101, 95, 98, 117, 105, 108, 100, 101, 114]], [], []}}}], ["help"|{dict, 2, 16, 16, 8, 80, 48, {[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}, {{[], [], [], [], [], [], [], [], [], [], [], [["description", "Provides help information for the available tasks"]], [], [["handler", 115, 105, 110, 95, 104, 101, 108, 112]], [], []}}}]], [], [["depends"|{dict, 4, 16, 16, 8, 80, 48, {[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}, {{[], [], [], [], [], [], [["depends", "discover"]], [["callable"|true]], [], [], [], [["description", "Analyzes all of the dependencies in the project ", "and pulls down those that arn't curently available ", "locally"]], [], [["handler", 115, 105, 110, 95, 100, 101, 112, 101, 110, 100, 115]], [], []}}}]], [["check_depends"|{dict, 4, 16, 16, 8, 80, 48, {[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}, {{[], [], [], [], [], [], [["depends", "discover"]], [["callable"|false]], [], [], [], [["description", "Checks that dependencies have been run. ", "If dependencies have not been run attempts to ", "run depends task"]], [], [["handler", 115, 105, 110, 95, 100, 101, 112, 101, 110, 100, 115, 95, 99, 104, 101, 99, 107]], [], []}}}]], [], [], [["discover"|{dict, 3, 16, 16, 8, 80, 48, {[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}, {{[], [], [], [], [], [], [], [["callable"|false]], [], [], [], [["description", "Discovers information about the project and ", "updates the project information"]], [], [["handler", 115, 105, 110, 95, 100, 105, 115, 99, 111, 118, 101, 114]], [], []}}}]], [["analyze"|{dict, 3, 16, 16, 8, 80, 48, {[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}, {{[], [], [], [], [], [], [["depends", "build"]], [], [], [], [], [["description", "Runs dialyzer on the project and outputs information ", "to the user. This task may take a significant amount ", "of time"]], [], [["handler", 115, 105, 110, 95, 97, 110, 97, 108, 121, 122, 101]], [], []}}}]], [], [["doc"|{dict, 3, 16, 16, 8, 80, 48, {[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}, {{[], [], [], [], [], [], [["depends", "build"]], [], [], [], [], [["description", "Runs edoc across all sources in the project and ", "outputs it into the build area"]], [], [["handler", 115, 105, 110, 95, 101, 100, 111, 99]], [], []}}}]], [["clean"|{dict, 3, 16, 16, 8, 80, 48, {[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}, {{[], [], [], [], [], [], [["depends"]], [], [], [], [], [["description", "Removes the build area and everything underneath"]], [], [["handler", 115, 105, 110, 95, 99, 108, 101, 97, 110]], [], []}}}]], [["build"|{dict, 3, 16, 16, 8, 80, 48, {[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}, {{[], [], [], [], [], [], [["depends", "check_depends"]], [], [], [], [], [["description", 67, 111, 109, 112, 105, 108, 101, 115, 32, 97, 108, 108, 32, 111, 102, 32, 116, 104, 101, 32, 99, 111, 109, 112, 105, 108, 97, 98, 108, 101, 32, 102, 105, 108, 101, 115, 32, 105, 110, 32, 116, 104, 101, 32, 112, 114, 111, 106, 101, 99, 116]], [], [["handler", 115, 105, 110, 95, 101, 114, 108, 95, 98, 117, 105, 108, 100, 101, 114]], [], []}}}], ["test"|{dict, 3, 16, 16, 8, 80, 48, {[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}, {{[], [], [], [], [], [], [["depends", "build"]], [], [], [], [], [["description", 82, 117, 110, 115, 32, 97, 108, 108, 32, 111, 102, 32, 116, 104, 101, 32, 101, 120, 105, 115, 116, 105, 110, 103, 32, 101, 117, 110, 105, 116, 32, 117, 110, 105, 116, 32, 116, 101, 115, 116, 115, 32, 105, 110, 32, 116, 104, 101, 32, 112, 114, 111, 106, 101, 99, 116]], [], [["handler", 115, 105, 110, 95, 116, 101, 115, 116]], [], []}}}], ["shell"|{dict, 3, 16, 16, 8, 80, 48, {[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}, {{[], [], [], [], [], [], [["depends", "build"]], [], [], [], [], [["description", "Starts an erlang shell with all of the correct ", "paths preset so the developer can noodle with the ", "code to his hearts content"]], [], [["handler", 115, 105, 110, 95, 115, 104, 101, 108, 108]], [], []}}}]]}}}]], [], [], [["ignore_dirs", "_", "."], ["flavors"|{dict, 2, 16, 16, 8, 80, 48, {[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}, {{[], [], [], [], [["release"|{dict, 1, 16, 16, 8, 80, 48, {[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}, {{[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], [["build", 45, 68, 78, 79, 84, 69, 83, 84, 61, 49, 32, 45, 87, 49]]}}}]], [], [["development"|{dict, 1, 16, 16, 8, 80, 48, {[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}, {{[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], [["build", 43, 100, 101, 98, 117, 103, 95, 105, 110, 102, 111, 32, 45, 87, 49]]}}}]], [], [], [], [], [], [], [], [], []}}}]], [], [["ignore_apps"], ["default_task", 98, 117, 105, 108, 100]], [["config_dir", 99, 111, 110, 102, 105, 103]], [], [], [], [["build"|{dict, 2, 16, 16, 8, 80, 48, {[], [], [], [], [], [], [], [], [], [], [], [], [], [], [], []}, {{[], [], [], [], [], [], [], [], [["args"]], [], [], [], [], [], [["task"|undefined]], []}}}]]}}}, #Ref<0.0.0.94>}, {{badrecord, dict}, [{dict, fold_dict, 3}, {fconf_engine, handle_call, 3}, {gen_server, handle_msg, 6}, {proc_lib, init_p, 5}]}]} {error_logger, {{2008, 2, 28}, {14, 27, 26}}, crash_report, [[{pid, <0.70.0>}, {registered_name, []}, {error_info, {{badrecord, dict}, [{dict, fold_dict, 3}, {fconf_engine, handle_call, 3}, {gen_server, handle_msg, 6}, {proc_lib, init_p, 5}]}}, {initial_call, {gen, init_it, [gen_server, <0.34.0>, <0.34.0>, fconf_engine, [#Ref<0.0.0.94>, #Fun], []]}}, {ancestors, [fconf_conf_sup, fconf_sup, <0.31.0>]}, {messages, []}, {links, [<0.34.0>]}, {dictionary, []}, {trap_exit, false}, {status, running}, {heap_size, 17711}, {stack_size, 21}, {reductions, 7529}], []]} {error_logger, {{2008, 2, 28}, {14, 27, 26}}, supervisor_report, [{supervisor, {local, fconf_conf_sup}}, {errorContext, child_terminated}, {reason, {{badrecord, dict}, [{dict, fold_dict, 3}, {fconf_engine, handle_call, 3}, {gen_server, handle_msg, 6}, {proc_lib, init_p, 5}]}}, {offender, [{pid, <0.70.0>}, {name, fconf_engine}, {mfa, {fconf_engine, start_link, [#Ref<0.0.0.94>, #Fun]}}, {restart_type, temporary}, {shutdown, 2000}, {child_type, worker}]}]} {error_logger, {{2008, 2, 28}, {14, 27, 26}}, "unexpected error ~p: ~p~n", [{{{badrecord, dict}, [{dict, fold_dict, 3}, {fconf_engine, handle_call, 3}, {gen_server, handle_msg, 6}, {proc_lib, init_p, 5}]}, {gen_server, call, [<0.70.0>, {parse, "/home/walrus/erlang_1/_build.cfg"}, 5000]}}, [{gen_server, call, 3}, {sin_engine, process_build_config, 3}, {sin_engine, start_run, 3}, {sin_engine, run_engine, 3}, {sin_engine, init, 1}, {gen_server, init_it, 6}, {proc_lib, init_p, 5}]]} {error_logger, {{2008, 2, 28}, {14, 27, 26}}, "run complete~n", []}

Ошибка была в том что в конфиге (приведен весь конфиг):
project : { name : voip vsn : "1.0" ), repositories : ["http://repo.elware.org/pub"]

Вместо } стоит ). Определенно, понимание сообщений sinan-а требует некоторых навыков ....

Standalone connection pool

2008-02-08T02:31:00.007+10:00

В одном из проектов на яве мне понадобился connection pool, без него соединения с базой получались слишком частые. После определенного поиска обнаружил DBCP от apache и статью на vingrad-e

DBCP мне не очень понравился, дело вкуса, конечно, но слишком много зависимостей. Да и тяжеловат он для мелкого проекта. Vingrad-овский connection pool - делает немного не то что хотелось кэширует statements.. И отсутствует обработка случаев, когда, к примеру база умрет (на время)..

Критика без конкретных предложений - критиканство. Так что взял и написал как нравится самому. Вот что получилось:

Итак. Общая идея:

Программа использует connection pool по шаблону:

Инициализация:


 ConnectionPool pool = ConnectionPool.getInstance();
 pool.setUsername("user1");
 pool.setPassword("bebebe");
 pool.setPath("jdbc:postgresql://hostname/main");
 pool.setClassName("org.postgresql.Driver");
 pool.setPoolsize(5); // держать 5 коннекций
 if (! pool.init() ) System.exit(100);

Тут все просто, берем экземпляр connectionpool-а (проект небольшой, так что оформим его в виде singleton), устанавливаем параметры, и если не удалось инициализировать, то не судьба и программу выполнять...
И дальше, в том месте где используется соединение, что-то вроде:


  Connection dbconnection = ConnectionPool.getConnection();
   try {
       ....
   } finaly
   {
       ConnectionPool.releaseConnection(dbconnection);
   }

Тут, если посмотреть, то connection берется не из экземпляра connection pool, а из статического метода в классе. И таким же образом отдается. Если у нас connection pool в виде singleton - зачем переливать из пустого в порожнее, брать по очереди connection pool и затем из него connection? Взять экземпляр connection pool я могу и сам в статическом методе. Мелочь, но писать программы проще...

Как это все реализлвано.


import java.sql.Connection;
import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.logging.Logger;


public class ConnectionPool {

    private static ConnectionPool instance;

    private ConnectionPool() {
        connections =  new ConcurrentLinkedQueue();
    }

    public static ConnectionPool getInstance() {
        if (instance == null) instance = new ConnectionPool();
        return instance;
    }


    public static Connection getConnection() {
        return getInstance().getInstanceConnection();
    }

    public static void releaseConnection(Connection c) {
        getInstance().releaseInstanceConnection(c);
    }

    /**
     * Выделить соединение из пула.
     * логика такая:
     * если не пустой - взять соединение из пула, проверить на валидность
     * и вернуть. невалидные соединения сразу убиваем.
     * если пул пустой - сделать новое соединение и вернуть его. Если не смогли
     * сделать новое соединение (типа DB сервер умер) - просто жалуемся в лог
     * и возвращаем null
     */

    private Connection getInstanceConnection() {
        if (! alreadyInitialized){
            log.severe("improper using of db pool (getConnection without init)");
            return null;
        };
        Connection currentConnection;
        do {
                currentConnection = connections.poll();
                if (currentConnection == null) break; //пустой пул
                // если дохлое соединение - не будем его использовать
                if (! validConnection(currentConnection)) {
                    currentConnection = null;
                }
        } while (currentConnection == null);

        try{
            if (connections.size() == 0) {
                log.info("DB Pool depleted, add new connection");
                connections.add(java.sql.DriverManager
                        .getConnection(path, userName,password));
                currentConnection = connections.poll();
                if (! validConnection(currentConnection)) {
                    // не судьба. Сдаемся
                    throw new Exception("new connection also is not valid");
                }
            }
        } catch (Exception ie) {
            log.severe("cannot provide sql connection:"+ie);
            return null;
        };
        return currentConnection;
    }

    private void releaseInstanceConnection(Connection c) {
        if (! alreadyInitialized){
            log.severe("improper using of db pool (releseConnection without init)");
            return;
        };
        if (getCurrentSize() >= getMaxPoolSize()) {
            try { c.close(); } catch (Exception e) {};
        } else if (! validConnection(c) ) {
                // Не будем возвращать в пул дохлое соединение
        } else {
            connections.offer(c);
        }

    }

    private int maxPoolSize = 5;

    public int getMaxPoolSize() {
        return maxPoolSize;
    }

    public void setPoolsize(int maxPoolSize) {
        if (!alreadyInitialized) {
            this.maxPoolSize = maxPoolSize;
        } else {
            log.severe("setPoolsize after init. ignoring");
        }
    }

    public int getCurrentSize() {
        return connections.size();
    }

    private String userName;

    private String password;

    private String path;

    private String className;

    public String getUserName() {
        return userName;
    }

    public void setUsername(String userName) {
        if (!alreadyInitialized) {
            this.userName = userName;
        } else {
            log.severe("setUserName after init. ignoring");
        }
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        if (!alreadyInitialized) {
            this.password = password;
        } else {
            log.severe("setPassword after init. ignoring");
        }
    }

    public String getPath() {
        return path;
    }

    public void setPath(String path) {
        if (!alreadyInitialized) {
            this.path = path;
        } else {
            log.severe("Path after init. ignoring");
        }
    }

    public String getClassName() {
        return className;
    }

    public void setClassName(String className) {
        if (!alreadyInitialized) {
            this.className = className;
        } else {
            log.severe("setClassName after init. ignoring");
        }
    }

    /**
     * init - Инициализация пула сообщений
     * @return boolean - успешно ли инициализирован пул (true - все хорошо)
     */

    public synchronized boolean init() {
        log.entering("ConnectionPool","init");
        try {
            if (alreadyInitialized) {
                throw new Exception("Double init of db pool");
            }
            Class.forName(this.className);
            for (int i=1; i<=5; i++){
                connections.add(java.sql.DriverManager
                        .getConnection(path, userName,password));
            };
            alreadyInitialized = true;
            log.exiting("ConnectionPool","init");
            return true;
        } catch (Exception e) {
            log.severe("Cannot init db pool:"+e);
        }
        log.exiting("ConnectionPool","init");
        return false;
    }

    private static Logger log = Logger.getLogger("dbpool");

    /**
     * Хранилище для коннекций
     */

    private ConcurrentLinkedQueue connections;

    /**
     * переменная предотвращающая двойную инициализацию DB pool
     */
    private boolean alreadyInitialized = false;
    /**
     * Проверка что соединение до сих пор живо. Если есть проблемы, мы его
     * просто убьем
     *
     *  Проверяем просто делая setAutoCommit. Если никаких exceptions
     *  не последовало, считаем что все в порядке.
     */

    private boolean validConnection(java.sql.Connection c) {
        try {
            boolean status = c.getAutoCommit();
            c.setAutoCommit(! status);
            c.setAutoCommit(status);
        } catch (Exception e) {
            try { c.close(); } catch (Exception notImportant) {};
            log.info("Dead sql connection detected");
            return false;
        }
        return true;
    }

}

Несколько попутных замечаний: Держится 5 соединений (по умолчанию, может быть изменено в setPoolsize() ), если программа просит больше соединений, будут устанавливаться новые соединения с базой. Просто они будут закрываться, когда в них пропадет нужда. Так что poolsize - это сколько соединений будет повторно использоваться.