隨筆 - 18, 文章 - 0, 評論 - 8, 引用 - 0
          數(shù)據(jù)加載中……

          2008年8月23日

          CyclicBarrier 簡單舉例

          一句話解釋:預(yù)備~~~開始

           1 import java.util.concurrent.BrokenBarrierException;
           2 import java.util.concurrent.CyclicBarrier;
           3 
           4 import org.slf4j.Logger;
           5 import org.slf4j.LoggerFactory;
           6 
           7 public class CyclicBarrierLearn {
           8     
           9     private Logger log = LoggerFactory.getLogger(CyclicBarrierLearn.class);
          10     
          11     private class Work extends Thread {
          12         
          13         private String name;
          14         private CyclicBarrier cyclicBarrier;
          15         
          16         public Work(String name, CyclicBarrier cyclicBarrier) {
          17             this.name = name;
          18             this.cyclicBarrier = cyclicBarrier;
          19         }
          20         
          21         @Override
          22         public void run() {
          23             try {
          24                 log.debug("thread name: " + name + " waiting work");
          25                 cyclicBarrier.await();
          26                 log.debug("thread name: " + name + " working");
          27             } catch (InterruptedException e) {
          28                 e.printStackTrace();
          29             } catch (BrokenBarrierException e) {
          30                 e.printStackTrace();
          31             }
          32             
          33         }
          34     }
          35     
          36     public void cyclicBarrier() {
          37         CyclicBarrier cyclicBarrier = new CyclicBarrier(50, new Runnable() {
          38             
          39             @Override
          40             public void run() {
          41                 log.debug("let's begin work");
          42             }
          43         });
          44         
          45         for (int i = 0; i < cyclicBarrier.getParties(); i++) {
          46             Work work = new Work(String.valueOf(i), cyclicBarrier);
          47             work.start();
          48         }
          49         
          50     }
          51 
          52     public static void main(String[] args) {
          53         CyclicBarrierLearn cyclicBarrierLearn = new CyclicBarrierLearn();
          54         cyclicBarrierLearn.cyclicBarrier();
          55 
          56     }
          57 
          58 }
          59 

          posted @ 2017-07-13 11:39 丑男 閱讀(179) | 評論 (0)編輯 收藏

          CountDownLatch 簡單舉例

          一句話解釋:主線程阻塞,其他線程完成后,主線程被喚醒后繼續(xù)執(zhí)行

           1 import java.util.Random;
           2 import java.util.concurrent.CountDownLatch;
           3 
           4 import org.slf4j.Logger;
           5 import org.slf4j.LoggerFactory;
           6 
           7 public class CountDownLatchLearn {
           8     
           9     private Logger log = LoggerFactory.getLogger(CountDownLatchLearn.class);
          10     private CountDownLatch countDownLatch;
          11     
          12     public CountDownLatchLearn() {
          13         countDownLatch = new CountDownLatch(50);
          14     }
          15     
          16     public void countDown() {
          17         Long count = countDownLatch.getCount();
          18         log.debug("countDownLatch count is:" + count.toString());
          19         
          20         for (int i = 0; i < count; i++) {
          21             Work work = new Work(String.valueOf(i), countDownLatch);
          22             work.start();
          23         }
          24         try {
          25             countDownLatch.await();
          26         } catch (InterruptedException e) {
          27             e.printStackTrace();
          28         }
          29         log.debug("work finish!!!");
          30     }
          31     
          32     private class Work extends Thread {
          33         
          34         private String name;
          35         private CountDownLatch countDownLatch;
          36         
          37         public Work(String name, CountDownLatch countDownLatch) {
          38             this.name = name;
          39             this.countDownLatch = countDownLatch;
          40         }
          41         
          42         @Override
          43         public void run() {
          44             Random r = new Random();
          45             int sleep = r.nextInt(2000);
          46             try {
          47                 log.debug("thread sleep: "+ sleep);
          48                 Thread.sleep(sleep);
          49             } catch (InterruptedException e) {
          50                 e.printStackTrace();
          51             }
          52             log.debug("thread: " + name + ": do work");
          53             countDownLatch.countDown();
          54         }
          55     }
          56 
          57     public static void main(String[] args) {
          58         System.out.println("main start!!!");
          59         
          60         CountDownLatchLearn countDownLatchLearn = new CountDownLatchLearn();
          61         countDownLatchLearn.countDown();
          62         
          63         System.out.println("main end!!!");
          64     }
          65 
          66 }

          posted @ 2017-07-13 11:18 丑男 閱讀(315) | 評論 (0)編輯 收藏

          mysql 5.7 for windows安裝過程

          環(huán)境說明:

          OSwindows 7 64bit Databasemysql-5.7.18-winx64 Noinstall版本

           

          1. 解壓Mysql安裝目錄

          2. 編寫my.ini配置文件

          3. mysqld --defaults-file=../my.ini --initialize

          4. ALTER USER 'root'@'localhost' IDENTIFIED BY 'password';

          5. mysql –u root –p

          6. 密碼在logs/*.err日志中

           
          my.ini文件內(nèi)容

           1 # my.ini文件內(nèi)容
           2 # For advice on how to change settings please see
           3 # http://dev.mysql.com/doc/refman/5.7/en/server-configuration-defaults.html
           4 # *** DO NOT EDIT THIS FILE. It's a template which will be copied to the
           5 # *** default location during install, and will be replaced if you
           6 # *** upgrade to a newer version of MySQL.
           7 
           8 [mysqld]
           9 
          10 # Remove leading # and set to the amount of RAM for the most important data
          11 # cache in MySQL. Start at 70% of total RAM for dedicated server, else 10%.
          12 # innodb_buffer_pool_size = 128M
          13 
          14 # Remove leading # to turn on a very important data integrity option: logging
          15 # changes to the binary log between backups.
          16 # log_bin
          17 
          18 # These are commonly set, remove the # and set as required.
          19 basedir=D:\\mysql-5.7.18-winx64
          20 datadir=D:\\mysql-5.7.18-winx64\\data
          21 # port = ..
          22 # server_id = ..
          23 
          24 
          25 # Remove leading # to set options mainly useful for reporting servers.
          26 # The server defaults are faster for transactions and fast SELECTs.
          27 # Adjust sizes as needed, experiment to find the optimal values.
          28 # join_buffer_size = 128M
          29 # sort_buffer_size = 2M
          30 # read_rnd_buffer_size = 2M 
          31 
          32 sql_mode=NO_ENGINE_SUBSTITUTION,STRICT_TRANS_TABLES
          33 
          34 long_query_time=0.1
          35 slow_query_log=on
          36 slow_query_log_file=D:\\mysql-5.7.18-winx64\\logs\\mysqlslow.log
          37 

          posted @ 2017-07-10 00:53 丑男 閱讀(218) | 評論 (0)編輯 收藏

          添加用戶【備份】

          useradd -g 501 -s /sbin/nologin builder

          posted @ 2013-05-06 17:25 丑男 閱讀(130) | 評論 (0)編輯 收藏

          [ZT]Java虛擬機(jī)JVM的調(diào)優(yōu)參數(shù)選擇

          在任何一個(gè)的生產(chǎn)系統(tǒng)上線前,系統(tǒng)性能調(diào)優(yōu)(Tuning)都是很重要的一步。通常,應(yīng)用系統(tǒng)的軟硬件的缺省值都是給開發(fā)平臺(或小規(guī)模系統(tǒng))設(shè)計(jì)的,用來跑生產(chǎn)系統(tǒng)幾乎都無法發(fā)揮出軟硬件的最佳性能。有時(shí),系統(tǒng)調(diào)優(yōu)前后的性能會(huì)差好幾倍。另一方面,由于應(yīng)用程序的開發(fā)人員通常都是針對功能作開發(fā)的,因此,開發(fā)硬件都是比生產(chǎn)環(huán)境要小的機(jī)器。例如,生產(chǎn)系統(tǒng)是一臺8個(gè)CPU,64GB內(nèi)存服務(wù)器,而開發(fā)服務(wù)器可能只有1個(gè)CPU和4GB內(nèi)存。所以,在開發(fā)人員中常常不具備做性能方面測試的軟硬件環(huán)境。另外,有的程序員甚至在開發(fā)時(shí)都沒有考慮到多用戶并發(fā)的環(huán)境,程序中存在單點(diǎn)瓶頸等問題。在做壓力測試和調(diào)優(yōu)時(shí),往往就會(huì)發(fā)現(xiàn)這些關(guān)鍵點(diǎn)。

            由于應(yīng)用系統(tǒng)是個(gè)軟硬件的完整統(tǒng)一體,系統(tǒng)調(diào)優(yōu)往往需要涉及硬件、網(wǎng)絡(luò)、操作系統(tǒng)、中間件,應(yīng)用程序和數(shù)據(jù)庫等方面。在調(diào)優(yōu)的過程中,往往需要發(fā)現(xiàn)存在瓶頸的地方(也就是導(dǎo)致系統(tǒng)變慢的部分),分析原因,從而改進(jìn)和確定較優(yōu)的參數(shù)。

            我們在作JVM的調(diào)優(yōu)前,通常先要了解運(yùn)行的硬件平臺,操作系統(tǒng)和中間件,然后針對這些情況配置相應(yīng)的系統(tǒng)參數(shù),在測試中不斷完善參數(shù)。由于性能調(diào)優(yōu)需要對系統(tǒng)非常了解,并且需要豐富的經(jīng)驗(yàn),因此不是一件容易的事情。這里介紹一些很好的參考資料,就是SPEC.org的網(wǎng)站。這是硬件廠商公布benchmark測試結(jié)果的地方,通常硬件廠商會(huì)把系統(tǒng)調(diào)到最優(yōu)化才公布結(jié)果的,因此很有借鑒意義。常見和JVM有關(guān)的benchmark值主要有SPECjAppServer2004和SPECjbb2005。前者是J2EE應(yīng)用服務(wù)器的性能指標(biāo),后者是服務(wù)器端Java虛擬機(jī)的性能指標(biāo)。給大家介紹這個(gè)網(wǎng)站的目的是說大家可以參考硬件廠商給出的JVM配置,在根據(jù)自己應(yīng)用環(huán)境的特點(diǎn),較快的得出較好的參數(shù)。例如,這個(gè)網(wǎng)頁給出了SUN公司T5120服務(wù)器+應(yīng)用服務(wù)器9.1 +JDK1.5的SPECjAppServer2004值是8,439.36:

            http://www.spec.org/jAppServer2004/results/res2007q4/jAppServer2004-20071106-00092.html

            我們現(xiàn)在要關(guān)心的不是Benchmark的值(注:實(shí)際上,Sun公司的這個(gè)值是個(gè)很不錯(cuò)的結(jié)果),而是留意在這種環(huán)境下JVM的參數(shù)配置,可以找到一個(gè)欄目“Notes / Tuning Information”:

            JVM Options: -server -XX:+AggressiveHeap

          -Xmx2560m -Xms2560m -Xmn1024m -Xss128k

          -XX:PermSize=256m

          -XX:+DisableExplicitGC

          -XX:ParallelGCThreads=24

          -XX:LargePageSizeInBytes=256m

          -XX:+UseParallelOldGC

          -XX:+AggressiveOpts

          -DAllowManagedFieldsInDefaultFetchGroup=true

          -DAllowMediatedWriteInDefaultFetchGroup=true

          -XX:-UseBiasedLocking

          -Dcom.sun.ejb.containers.readonly.relative.refresh.mode=true

          -Dcom.sun.jts.dblogging.insertquery=insert into

          txn_log_table_0 values (
          ? , ? , ? )

          -Dcom.sun.jts.dblogging.deletequery=delete from

          txn_log_table_0 where localtid
          = ? and servername = ?

          -Dcom.sun.jdo.spi.persistence.support.sqlstore.

          MULTILEVEL_PREFETCH
          =true

            那么上面那些參數(shù)是什么意思呢?上述段落中“-XX”的參數(shù)是SUN JVM的擴(kuò)展選項(xiàng),其中以下的這些都是和垃圾回收(GC)有關(guān):

            -XX:PermSize=256m

          -XX:+DisableExplicitGC

          -XX:ParallelGCThreads=24

          -XX:+UseParallelOldGC

          -XX:+AggressiveHeap

            下面這個(gè)選項(xiàng)是選擇大的內(nèi)存頁面:

            -XX:LargePageSizeInBytes=256m

            "-XX:+AggressiveOpts"是一些試驗(yàn)性優(yōu)化參數(shù),“-XX:-UseBiasedLocking”是非競爭性的同步選項(xiàng)。

            而選項(xiàng)“-Xmx2560m -Xms2560m -Xmn1024m -Xss128k”則是初始堆棧的內(nèi)存值,注意-Xmx和-Xms的值是一樣的,這樣系統(tǒng)性能會(huì)較平穩(wěn)些。

            至于這些參數(shù)詳細(xì)代表什么意義,大家可以google一下就很容易了解。這是Sun網(wǎng)站上的說明,有興趣的可以讀一下: http://java.sun.com/performance/reference/whitepapers/tuning.html

            如果你的應(yīng)用系統(tǒng)是JDK1.5,硬件是T5120,操作系統(tǒng)是Solaris,那么這些參數(shù)就很有借鑒意義。如果你的硬件系統(tǒng)不是T5120,但是使用SUN的JDK1.5 ,這些參數(shù)也是有一定參考作用。當(dāng)然,最理想的是選擇一個(gè)和自己的環(huán)境最近似的結(jié)果來參考。大多數(shù)軟硬件的測試結(jié)果都可以在SPEC.org上找到,如果你的系統(tǒng)是J2EE的3層架構(gòu),可以用jAppServer2004指標(biāo),如果是純JAVA的應(yīng)用,可用jbb2005的結(jié)果:

            http://www.spec.org/jAppServer2004/

            http://www.spec.org/jbb2005/

            需要注意的是,這些調(diào)優(yōu)參數(shù)只是提供了一個(gè)思路,具體是否合適你的應(yīng)用還要看實(shí)測結(jié)果。

          posted @ 2009-04-29 19:24 丑男 閱讀(275) | 評論 (0)編輯 收藏

          [轉(zhuǎn)帖]Hibernate常用保存

          hibernate對于對象的保存提供了太多的方法,他們之間有很多不同,這里細(xì)說一下,以便區(qū)別:
          一、預(yù)備知識:
          在所有之前,說明一下,對于hibernate,它的對象有三種狀態(tài),transient、persistent、detached
          下邊是常見的翻譯辦法:
          transient:瞬態(tài)或者自由態(tài)
          persistent:持久化狀態(tài)
          detached:脫管狀態(tài)或者游離態(tài)
          脫管狀態(tài)的實(shí)例可以通過調(diào)用save()、persist()或者saveOrUpdate()方法進(jìn)行持久化。
          持久化實(shí)例可以通過調(diào)用 delete()變成脫管狀態(tài)。通過get()或load()方法得到的實(shí)例都是持久化狀態(tài)的。
          脫管狀態(tài)的實(shí)例可以通過調(diào)用 update()、0saveOrUpdate()、lock()或者replicate()進(jìn)行持久化。
          save() 和persist()將會(huì)引發(fā)SQL的INSERT,delete()會(huì)引發(fā)SQLDELETE,而update()或merge()會(huì)引發(fā) SQLUPDATE.對持久化(persistent)實(shí)例的修改在刷新提交的時(shí)候會(huì)被檢測到,它也會(huì)引起 SQLUPDATE.saveOrUpdate()或者replicate()會(huì)引發(fā)SQLINSERT或者UPDATE
          二、save 和update區(qū)別
          把這一對放在第一位的原因是因?yàn)檫@一對是最常用的。
          save的作用是把一個(gè)新的對象保存
          update是把一個(gè)脫管狀態(tài)的對象保存
          三、update 和saveOrUpdate區(qū)別
          這個(gè)是比較好理解的,顧名思義,saveOrUpdate基本上就是合成了save和update引用hibernate reference中的一段話來解釋他們的使用場合和區(qū)別。
          通常下面的場景會(huì)使用update()或saveOrUpdate():
          程序在第一個(gè)session中加載對象
          該對象被傳遞到表現(xiàn)層
          對象發(fā)生了一些改動(dòng)
          該對象被返回到業(yè)務(wù)邏輯層
          程序調(diào)用第二個(gè)session的update()方法持久這些改動(dòng)
          saveOrUpdate()做下面的事:
          如果對象已經(jīng)在本session中持久化了,不做任何事
          如果另一個(gè)與本session關(guān)聯(lián)的對象擁有相同的持久化標(biāo)識(identifier),拋出一個(gè)異常
          如果對象沒有持久化標(biāo)識(identifier)屬性,對其調(diào)用save()
          如果對象的持久標(biāo)識(identifier)表明其是一個(gè)新實(shí)例化的對象,對其調(diào)用save()
          如果對象是附帶版本信息的(通過或) 并且版本屬性的值表明其是一個(gè)新實(shí)例化的對象,save()它。
          四、persist和save區(qū)別
          這個(gè)是最迷離的一對,表面上看起來使用哪個(gè)都行,在hibernate reference文檔中也沒有明確的區(qū)分他們。
          這里給出一個(gè)明確的區(qū)分。(可以跟進(jìn)src看一下,雖然實(shí)現(xiàn)步驟類似,但是還是有細(xì)微的差別)
          1.persist把一個(gè)瞬態(tài)的實(shí)例持久化,但是并"不保證"標(biāo)識符被立刻填入到持久化實(shí)例中,標(biāo)識符的填入可能被推遲到flush的時(shí)間。
          2.persist" 保證",當(dāng)它在一個(gè)transaction外部被調(diào)用的時(shí)候并不觸發(fā)一個(gè)Sql Insert,這個(gè)功能是很有用的,當(dāng)我們通過繼承Session/persistence context來封裝一個(gè)長會(huì)話流程的時(shí)候,一個(gè)persist這樣的函數(shù)是需要的。
          3.save"不保證"第2條,它要返回標(biāo)識符,所以它會(huì)立即執(zhí)行Sql insert,不管是不是在transaction內(nèi)部。
          五、saveOrUpdateCopy,merge和update區(qū)別
          首先說明merge是用來代替saveOrUpdateCopy的,然后比較update和merge,update的作用上邊說了,這里說一下merge的作用。
          如果session中存在相同持久化標(biāo)識(identifier)的實(shí)例,用用戶給出的對象的狀態(tài)覆蓋舊有的持久實(shí)例
          如果session沒有相應(yīng)的持久實(shí)例,則嘗試從數(shù)據(jù)庫中加載,或創(chuàng)建新的持久化實(shí)例,最后返回該持久實(shí)例
          用戶給出的這個(gè)對象沒有被關(guān)聯(lián)到session上,它依舊是脫管的
          重點(diǎn)是最后一句:
          當(dāng)我們使用update的時(shí)候,執(zhí)行完成后,我們提供的對象A的狀態(tài)變成持久化狀態(tài)
          但當(dāng)我們使用merge的時(shí)候,執(zhí)行完成,我們提供的對象A還是脫管狀態(tài),hibernate或者new了一個(gè)B,或者檢索到一個(gè)持久對象,并把我們提供的對象A的所有的值拷貝到這個(gè)B,執(zhí)行完成后B是持久狀態(tài),而我們提供的A還是托管狀態(tài)。
          六、flush和update區(qū)別
          這兩個(gè)的區(qū)別好理解
          update操作的是在脫管狀態(tài)的對象,而flush是操作的在持久狀態(tài)的對象。
          默認(rèn)情況下,一個(gè)持久狀態(tài)的對象是不需要update的,只要你更改了對象的值,等待hibernate flush就自動(dòng)保存到數(shù)據(jù)庫了。hibernate flush發(fā)生再幾種情況下:
          1.調(diào)用某些查詢的時(shí)候
          2.transaction commit的時(shí)候
          3.手動(dòng)調(diào)用flush的時(shí)候
          七、lock和update區(qū)別
          update是把一個(gè)已經(jīng)更改過的脫管狀態(tài)的對象變成持久狀態(tài)
          lock是把一個(gè)沒有更改過的脫管狀態(tài)的對象變成持久狀態(tài)
          對應(yīng)更改一個(gè)記錄的內(nèi)容,兩個(gè)的操作不同:
          update的操作步驟是:
          更改脫管的對象->調(diào)用update
          lock的操作步驟是:
          調(diào)用lock把對象從脫管狀態(tài)變成持久狀態(tài)——>更改持久狀態(tài)的對象的內(nèi)容——>等待flush或者手動(dòng)flush

          posted @ 2008-08-23 21:22 丑男 閱讀(249) | 評論 (0)編輯 收藏

          主站蜘蛛池模板: 临洮县| 长兴县| 乡城县| 麻栗坡县| 南投市| 化州市| 屯昌县| 定陶县| 平罗县| 乐昌市| 灌阳县| 台山市| 怀集县| 于都县| 瑞安市| 鞍山市| 全椒县| 文成县| 葫芦岛市| 丰县| 商洛市| 临沭县| 安徽省| 通渭县| 栾川县| 黔东| 竹山县| 图木舒克市| 靖边县| 民权县| 津南区| 青岛市| 余庆县| 博湖县| 图们市| 龙口市| 祁阳县| 商南县| 志丹县| 华亭县| 庆城县|