在路上

路上有驚慌，路上有理想

BlogJava :: 首頁 :: 聯系 :: 聚合

:: 管理

28 Posts :: 1 Stories :: 10 Comments :: 0 Trackbacks

常用鏈接

留言簿(13)

我參與的團隊

隨筆分類

隨筆檔案

搜索

閱讀排行榜

評論排行榜

2010年12月10日 #

記錄：java批量生成圖片的問題

1.linux安裝字體
以微軟雅黑為例，找到msyh.ttf ,copy至下面的文件夾

usr/share/fonts/msyh

執行命令：fc-cache -fv

重啟jvm即可
2.drawString 部分代碼

private static BufferedImage drawString(int type, boolean isWhite,
           int width, int height, String price, Font font_money, Font font,
           Graphics2D g2d, Rectangle2D bounds, Rectangle2D bounds_money) {
       BufferedImage image;
       //透明背景
        image = g2d.getDeviceConfiguration().createCompatibleImage(width, height, Transparency.TRANSLUCENT);
       g2d.dispose();
       g2d = image.createGraphics();
       //反鋸齒字體
       g2d.setRenderingHint(RenderingHints.KEY_ANTIALIASING, RenderingHints.VALUE_ANTIALIAS_ON);
       if(!isWhite){
           //非白字
           g2d.setColor(new Color(236,0,137));
       }else{
             //白字
             g2d.setColor(new Color(255,255,255));
       }
       //字體居中
       double y = (height - bounds.getHeight()) / 2;
         double ascent = -bounds.getY();
         double baseY = y + ascent;

       g2d.setStroke(new BasicStroke(1));
       g2d.setFont(font_money);
       g2d.drawString(FONT_RMB_CHAR, -2, (int)baseY);
       g2d.setFont(font);
       g2d.drawString(price, (int)bounds_money.getWidth()-4, (int)baseY);
         g2d.dispose();
       return image;
   }

3.如果需要根據字符串的長度生成圖片的寬度，可以使用如下方法

Rectangle2D bounds = font.getStringBounds(price, context);
width = (int)(bounds.getWidth();

4.批量生成,使用java自帶的線程池，并使用CompletionService，目的是在線程處理結束后得到生成成功的ProductId

      public boolean generateImagesBatch(){
          boolean flag=true;
          ExecutorService exec = Executors.newFixedThreadPool(8);
           CompletionService<CallBack> completionService=
                    new ExecutorCompletionService<CallBack>(exec);
          long startTime=System.currentTimeMillis();
           String sql="select productId,price from prod";
           List<Map> skuList = this.cmsJdbcTemplate.queryForList(sql);
           for(Map map:skuList){
               String prodId=((BigDecimal)map.get("productId")).toString();
               double price=((BigDecimal)map.get("price")).doubleValue();
               completionService.submit(new CreateImageConcurrent(prodId,price,FontEnum.ONE,false));
                completionService.submit(new CreateImageConcurrent(prodId,price,FontEnum.TWO,false));            }
           long endTime=System.currentTimeMillis()-startTime;
           log.info("query db time>>>>>>>>>>>>>>"+endTime/1000);

           Future<CallBack> future;
           int count=skuList.size()*6;
           log.info("generateImagesBatch count:"+count);
           try {
               while(count>0){
                    future = completionService.take();
                   CallBack callBack = future.get();
                   if(null!=callBack){
                       count--; log.info("generateImagesBatch prod id:"+callBack.getSuccesMessage());                    }
                }
           endTime=System.currentTimeMillis()-startTime;
           log.info("create images time>>>>>>>>>>>>>>"+endTime/1000);
           log.info("generateImagesBatch success!");
           flag=true;
           } catch (ExecutionException e) {
               flag=false;
               log.error("generateImagesBatch fail::ExecutionException::"+e.getMessage());
           } catch (InterruptedException e) {
               flag=false;
               log.error("generateImagesBatch fail::InterruptedException::"+e.getMessage());
           }finally{
               exec.shutdown();
           }
           return flag;
      }

posted @ 2012-04-18 11:35 阮步兵閱讀(1860) | 評論 (0) | 編輯收藏

Java多線程筆記(4)

以下只是一些概念

1.Semaphore與CountDownLatch
Semaphore 可用于控制特定資源請求（線程/操作）數量
 CountDownLatch 在功能上類似于 Semaphore。區別是，Semaphore允許一次一個線程的話，CountDownLatch可以允許多個線程在特定的時間一起執行。

2.CAS操作
根據英文直譯其實可以理解其含義，compare and set.

CAS 操作包含三個操作數 —— 內存位置（V）、預期原值（A）和新值(B)。如果內存位置的值與預期原值相匹配，那么處理器會自動將該位置值更新為新值。否則，處理器不做任何操作。CAS 認為位置 V 應該包含值 A；如果包含該值，則將 B 放到這個位置；否則，不要更改該位置，只告訴我這個位置現在的值即可通常將 CAS 用于同步的方式是從地址 V 讀取值 A，執行多步計算來獲得新值 B，然后使用 CAS 將 V 的值從 A 改為 B。如果 V 處的值尚未同時更改，則 CAS 操作成功。

3.ABA問題

因為在更改 V 之前，CAS 主要詢問“V 的值是否仍為 A”，所以在第一次讀取 V 以及對 V 執行 CAS 操作之前，如果將值從 A 改為 B，然后再改回 A，會使基于 CAS 的算法混亂。在這種情況下，CAS 操作會成功，但是在一些情況下，結果可能不是您所預期的。這類問題稱為 ABA 問題。

4.原子操作

A與B兩個操作。從執行A的線程看，當其他線程執行B時，要么B全部執行完成，要么一點都不執行。這樣A與B互為原子操作。要保證數據狀態的一致性，要在單一的原子操作中更新所有相關聯的狀態。

5.可見性

在單線程環境下，讀寫操作都在一個線程內完成，不存在可見性問題。但是，當讀與寫操作不在同一個線程內時，就需要有可見性的要求——即可變的共享變量對所有線程都是可見的。

6.重排序

JVM實現中，線程內部維持順序化語義。如果程序的最終結果等同于它在嚴格的順序化環境下的結果，那么指令的執行順序就可能與代碼的順序不一致。這個過程通過叫做指令的重排序。比如Java存儲模型允許編譯器重排序操作指令，在寄存器中緩存數值，還允許CPU重排序，并在處理器的緩存中緩存數值。

當然，在沒有同步的多線程情況下，編譯器，處理器，運行時安排操作的執行順序可能完全出人意料。

7.內部鎖

每個Java對象都可以隱士的扮演一個用于同步的鎖的角色。比如synchronized(object){},執行線程進入synchronized塊之前自動獲得鎖。無論是正確執行或是拋出異常，最終都會釋放該鎖。內部鎖是一種互斥鎖(mutex)——至多只有一個線程可以擁有鎖。JDK中有該鎖的實現。

8.鎖與內存

鎖不僅僅是關于同步與互斥，也是關于內存可見性的。為了保證所有線程都能訪問共享變量的最新值，讀和寫的線程必須使用公用的鎖進行同步。

9.鎖與volatile

加鎖可以保證可見性與原子性，volatile只能保證可見性。

10.happen-before法則

Java存儲模型有一個happens-before原則，就是如果動作B要看到動作A的執行結果（無論A/B是否在同一個線程里面執行），那么A/B就需要滿足happens-before關系。比如一個對象構造函數的結束happens-before與該對象的finalizer的開始

參考:https://www.ibm.com/developerworks/cn/java/j-jtp11234/

http://www.ibm.com/developerworks/cn/java/j-5things5.html

http://www.aygfsteel.com/xylz/archive/2010/07/03/325168.html

《Java 并發編程實踐》

posted @ 2010-12-15 18:18 阮步兵閱讀(1744) | 評論 (0) | 編輯收藏

BTrace 工具使用(1)

BTrace是一個實時監控工具，使用了java agent 和jvm attach技術，可以在product的情況下實時監控線上程序的運行情況。另，有插件可與visualVM一起使用。
不多說了，具體的可見:http://kenai.com/projects/btrace

下面介紹幾個Helloworld示例:
主要使用了btrace命令:btrace [pid] class

pid可由jps命令快速查詢

1.監控方法輸入參數:
@OnMethod(
                clazz="com.btrace.Person",
                method="/set.*/"
            )
            public static void anyRead(@ProbeClassName String pcn, @ProbeMethodName String pmn, AnyType[] args) {
                println(pcn);
                println(pmn);
                printArray(args);
            }

執行btract命令
后臺輸出:
com.btrace.Person
setId
[1, ]……

2.監控方法返回值
@OnMethod(
                 clazz="com.btrace.Person",
                 method="/get.*/",
                 location=@Location(Kind.RETURN)
               )
    public static void defineclass(@Return String cl) {
           println(Strings.strcat("getValue ", cl));
           Threads.jstack();
       }
執行btract命令
后臺輸出:
getValue gum
com.btrace.TestThread.main(TestThread.java:23)

3.監控jvm內存使用情況
@OnTimer(4000)
    public static void printMem() {
        println("Heap:");
        println(heapUsage());
        println("Non-Heap:");
        println(nonHeapUsage());
    }
執行btract命令
后臺輸出:
Heap:
init = 268435456(262144K) used = 26175176(25561K) committed = 251658240(245760K)
max = 492175360(480640K)
Non-Heap:
init = 12746752(12448K) used = 5892104(5754K) committed = 13598720(13280K) max =
100663296(98304K)
4.監控方法執行時間
   @TLS private static long startTime;

    @OnMethod(clazz="com.btrace.Person",method="setId")
    public static void onCall(){
        println("enter this method");
        startTime=timeMillis();
    }

    @OnMethod(clazz="com.btrace.Person",method="setId",location=@Location(Kind.RETURN))
    public static void onReturn(){
        println("method end!");
        println(strcat("Time taken ms",str(timeMillis()-startTime)));
    }
后臺輸出:
   enter this method
   method end!
   Time taken ms0
5.監控Thread start
@OnMethod(
        clazz="java.lang.Thread",
        method="start"
    )
    public static void func() {
        println("about to start a thread!");
    }
后臺輸出：about to start a thread!

posted @ 2010-12-10 18:30 阮步兵閱讀(3762) | 評論 (1) | 編輯收藏

在路上