- 浏览: 395281 次
- 性别:
- 来自: 杭州
文章分类
- 全部博客 (760)
- 股票日志 (26)
- Selenium (0)
- selenium 2 环境的搭建 (1)
- 并发 (7)
- 框架开发 (1)
- 动态代理 (2)
- Struts2 (2)
- POI (2)
- jdk (3)
- maven (31)
- spring (35)
- mysql (31)
- 工作机会 (3)
- xtream (1)
- oracle dbms_metadata GET_DDL (0)
- SSI (1)
- DB (61)
- powermock (4)
- java 基础 (25)
- 多线程 (11)
- 高手 (2)
- java 底层 (2)
- 专业网站 (1)
- 开发联想 (1)
- 开发联想 (1)
- bat文件 (2)
- 清queue 语句 (1)
- 清queue 语句 (1)
- jquery (7)
- html5 (1)
- Jenkins (10)
- Linux (17)
- 工作issue (2)
- tomcat log (3)
- jvm (23)
- 项目细节 (0)
- oracle (41)
- 泛型 (3)
- 新知识点 (1)
- 数据库ddl 语句 (0)
- AQ (2)
- jms (0)
- 网络资源 (6)
- github (6)
- Easymock (1)
- Dom 解析XML (1)
- windows命令 (2)
- java (7)
- 正则表达式 (5)
- sequence (1)
- oracle 表meta信息 (1)
- 小工具技巧 (1)
- 辅助工具 (1)
- Junit (1)
- 泛型 generic (2)
- Java程序设计 (1)
- cglib (2)
- 架构师之路 (1)
- 数据库连接池 (5)
- c3p0 (1)
- eclipse使用 (1)
- oracle sql plus (1)
- 码农人生 (3)
- SVN (15)
- sqlplus (2)
- jsoup (1)
- 网络爬虫 (2)
- 新技能 (1)
- zookeeper (4)
- hadoop (1)
- SVNKIT (1)
- 从工具到知识点的整理 (1)
- log4j (13)
- 读文件 (0)
- 转义字符 (1)
- command (1)
- web service (3)
- 锁 (1)
- shell 脚本 (1)
- 遇到的错误 (2)
- tomcat (14)
- 房产 (5)
- bootstrap jquery ui (1)
- easyui (2)
- 个人征信 (1)
- 读写分离 (1)
- 备份 (1)
- rmi (6)
- webservice (1)
- JMX (4)
- 内存管理 (3)
- java设计 (1)
- timer (1)
- lock (2)
- concurrent (2)
- collection (1)
- tns (1)
- java基础 (15)
- File (1)
- 本机资源 (1)
- bat (1)
- windows (4)
- 数据结构 (3)
- 代码安全 (1)
- 作用域 (1)
- 图 (2)
- jvm内存结构 (1)
- 计算机思想 (1)
- quartz (6)
- Mongo DB (2)
- Nosql (4)
- sql (5)
- 第三方Java 工具 jar 项目 (2)
- drools (1)
- java swing (2)
- 调用console (1)
- runtime (1)
- process (1)
- swing (2)
- grouplayout (1)
- dubbo (0)
- bootstrap (0)
- nodejs (2)
- SVN hooks (1)
- jdbc (3)
- jdbc error (1)
- precedure (1)
- partition_key (1)
- active mq (1)
- blob (2)
- Eclipse (6)
- web server (1)
- bootstrapt (2)
- struts (1)
- ajax (1)
- js call back (1)
- 思想境界拓展 (1)
- JIRA (1)
- log (1)
- jaxb (3)
- xml java互相转换 (1)
- 装修 (2)
- 互联网 (2)
- threadlocal (3)
- mybatis (22)
- xstream (1)
- 排序 (1)
- 股票资源 (1)
- RPC (2)
- NIO (3)
- http client (6)
- 他人博客 (1)
- 代理服务器 (1)
- 网络 (2)
- web (1)
- 股票 (5)
- deadlock (1)
- JConsole (2)
- activemq (3)
- oralce (1)
- 游标 (1)
- 12月13日道富内部培训 (0)
- grant (1)
- 速查 (2)
- classloader (4)
- netty (4)
- 设计模式 (2)
- 缓存 (2)
- ehcache (2)
- framework (1)
- 内存分析 (2)
- dump (1)
- memory (2)
- 多高线程,并发 (1)
- hbase (2)
- 分布式系统 (1)
- socket (3)
- socket (1)
- 面试问题 (1)
- jetty (2)
- http (2)
- 源码 (1)
- 日志 (2)
- jni (1)
- 编码约定 (1)
- memorycache (1)
- redis (13)
- 杂谈 (1)
- drool (1)
- blockingqueue (1)
- ScheduledExecutorService (1)
- 网页爬虫 (1)
- httpclient (4)
- httpparser (1)
- map (1)
- 单例 (1)
- synchronized (2)
- thread (1)
- job (1)
- hashcode (1)
- copyonwriteArrayList (2)
- 录制声音 (1)
- java 标准 (2)
- SSL/TLS (1)
- itext (1)
- pdf (1)
- 钻石 (2)
- sonar (1)
- unicode (1)
- 编码 (4)
- html (1)
- SecurityManager (1)
- 坑 (1)
- Restful (2)
- svn hook (1)
- concurrentHashMap (1)
- 垃圾回收 (1)
- vbs (8)
- visual svn (2)
- power shell (1)
- wmi (3)
- mof (2)
- c# (1)
- concurrency (1)
- 劳动法 (1)
- 三国志游戏 (2)
- 三国 (1)
- 洪榕 (2)
- 金融投资知识 (1)
- motan (1)
- tkmybatis mapper (1)
- 工商注册信息查询 (1)
- consul (1)
- 支付业务知识 (2)
- 数据库备份 (1)
- 字段设计 (1)
- 字段 (1)
- dba (1)
- 插件 (2)
- PropEdit插件 (1)
- web工程 (1)
- 银行业知识 (2)
- 国内托管银行 (1)
- 数据库 (1)
- 事务 (2)
- git (18)
- component-scan (1)
- 私人 (0)
- db2 (14)
- alias (1)
- 住房 (1)
- 户口 (1)
- fastjson (1)
- test (6)
- RSA (2)
- 密钥 (1)
- putty (1)
- sftp (1)
- 加密 (1)
- 公钥私钥 (3)
- markdown (1)
- sweet (1)
- sourcetree (1)
- 好工具 (1)
- cmd (1)
- scp (1)
- notepad++ (1)
- ssh免密登录 (1)
- https (1)
- ssl (2)
- js (2)
- h2 (1)
- 内存 (2)
- 浏览器 (1)
- js特效 (1)
- io (1)
- 乱码 (1)
- 小工具 (1)
- 每周技术任务 (1)
- mongodb (7)
- 内存泄漏 (1)
- 码云 (2)
- 如何搭建java 视频服务器 tomcat (1)
- 资源 (1)
- 书 (1)
- 四色建模法 (1)
- 建模 (1)
- 配置 (1)
- 职位 (1)
- nginx (1)
- excel (1)
- log4j2 (2)
- 做菜 (1)
- jmap (1)
- jspwiki (1)
- activiti (1)
- 工作流引擎 (1)
- 安卓 (1)
- acitviti 例子 (1)
- 二维码 (1)
- 工作流 (1)
- powerdesign (2)
- 软件设计 (1)
- 乐观锁 (1)
- 王者荣耀 (1)
- session (2)
- token (5)
- cookie (4)
- springboot (24)
- jwt (2)
- 项目路径 (1)
- magicbook (1)
- requestType (1)
- json (2)
- swagger (1)
- eolinker (1)
- springdata (1)
- springmvc (1)
- controlleradvice (1)
- profile (1)
- 银行四要素 (1)
- 支付人员资源 (1)
- 支付渠道 (1)
- yaml (1)
- 中文编码 (1)
- mongo (2)
- serializable (1)
- 序列化 (1)
- zyd (1)
- unittest (1)
- 工具 (1)
- Something (1)
- 通达信 (1)
- protobuf (1)
- 算法 (1)
- springcloud (2)
- hikari (1)
- rocketmq (7)
- cachecloud (1)
- serfj (1)
- axure (1)
- lombok (1)
- 分布式锁 (1)
- 线程 (2)
- 同步代码块 (1)
- cobar (1)
- mq (1)
- rabbitmq (1)
- 定时执行 (1)
- 支付系统 (3)
- 唱歌 (1)
- elasticjob (1)
- 定时任务 (1)
- 界面 (1)
- flink (2)
- 大数据 (1)
- 接私活 (0)
- 内部培训 (2)
最新评论
-
dannyhz:
做股票从短线 试水,然后 慢慢发现 波段和 中期的故事可挖, ...
搭台唱戏 -
dannyhz:
http://developer.51cto.com/art/ ...
如何自己开发框架 它的注意点是什么
自己做的 取sequence的 使用blockingqueue 和 ScheduledExecutorService例子
引用
在取 sequence的 dao里 用了一个 mock的 实现 ,然后 把queue的容量设置为3, 但是每次取可以取到4
这样第一次会把第4个元素 不放进去, 只放进去3个 ,
package com.ssc.dbcttool.seqgenerator; import java.util.List; public interface KeyDao { List<Long> getSequences(String seqName, Long capbility); } package com.ssc.dbcttool.seqgenerator; import java.util.ArrayList; import java.util.List; public class MockKeyDao implements KeyDao{ @Override public List<Long> getSequences(String seqName, Long capbility) { List<Long> longList = new ArrayList<Long>(); longList.add(1000L); longList.add(1001L); longList.add(1010L); longList.add(1100L); return longList; } }
package com.ssc.dbcttool.seqgenerator; public class KeyGeneratorClient { public static void main(String[] args) { SeqGeneratorImpl gen = new SeqGeneratorImpl(); gen.setGenerateKeysDao(new MockKeyDao()); System.out.println("key = " + gen.getSeqKey("aaa")); System.out.println("key = " + gen.getSeqKey("aaa")); System.out.println("key = " + gen.getSeqKey("aaa")); System.out.println("key = " + gen.getSeqKey("aaa")); System.out.println("key = " + gen.getSeqKey("aaa")); System.out.println("key = " + gen.getSeqKey("aaa")); System.out.println("key = " + gen.getSeqKey("aaa")); System.out.println("key = " + gen.getSeqKey("aaa")); System.out.println("key = " + gen.getSeqKey("aaa")); } }
package com.ssc.dbcttool.seqgenerator; import java.lang.Thread.UncaughtExceptionHandler; import java.util.List; import java.util.Map; import java.util.concurrent.BlockingQueue; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledThreadPoolExecutor; import java.util.concurrent.ThreadFactory; import java.util.concurrent.TimeUnit; import com.statestr.gcth.core.concurrency.DefaultThreadFactory; public class SeqGeneratorImpl { final int capacity = 3; ConcurrentMap<String, BlockingQueue<Long>> keyQueues = new ConcurrentHashMap<String, BlockingQueue<Long>>(); ScheduledExecutorService scheduler; public SeqGeneratorImpl() { scheduler = new ScheduledThreadPoolExecutor(2, new DefaultThreadFactory().daemon().eh( new UncaughtExceptionHandler() { public void uncaughtException(Thread t, Throwable e) { System.out.println("Thread " + t.getName() + " for Key Generator throw a UncaughtException."); } })); } public Long getSeqKey(String keyName) { Long key = null; BlockingQueue<Long> keyQueue = keyQueues.get(keyName); if (keyQueue == null) { keyQueue = getQueue(keyName); } try { key = keyQueue.take(); } catch (Exception e) { Thread.currentThread().interrupt(); System.out.println("Failed to get sequence for unknown reason, the operation is interrupted."); } return key; } synchronized BlockingQueue<Long> getQueue(String keyName) { BlockingQueue<Long> keyQueue = keyQueues.get(keyName); if (keyQueue == null) { keyQueue = new LinkedBlockingQueue<Long>(capacity); keyQueues.putIfAbsent(keyName, keyQueue); triggerTheTask(keyName, keyQueue); } return keyQueue; } void triggerTheTask(String name, BlockingQueue<Long> keyQueue) { scheduler.scheduleWithFixedDelay(new FetchKeyTask(name, keyQueue), 0, 3000, TimeUnit.MILLISECONDS); } protected class FetchKeyTask implements Runnable { private String keyName; private BlockingQueue<Long> keyQueue = null; public FetchKeyTask(BlockingQueue<Long> keyQueue) { this(null, keyQueue); } public FetchKeyTask(String keyName, BlockingQueue<Long> keyQueue) { this.keyName = keyName; this.keyQueue = keyQueue; } @Override public void run() { int remainingCapacity = keyQueue.remainingCapacity(); if (capacity * (1 - 0.5) < remainingCapacity) { try { List<Long> keys = getKeys(keyName, remainingCapacity); for (Long key : keys) { keyQueue.put(key); } } catch (InterruptedException e) { Thread.currentThread().interrupt(); System.out.println("key fetch task is interrupted."); } catch (Exception e) { System.out.println("key fetch task happens exception:"); } System.out.println("retrieve keys from database, the keys' amount is " + remainingCapacity); } } } protected List<Long> getKeys(String name, long capacity) { return generateKeysDao.getSequences(name, capacity); } protected KeyDao generateKeysDao; public void setGenerateKeysDao(KeyDao generateKeysDao) { this.generateKeysDao = generateKeysDao; } }
相关推荐
以下是一个简单的例子,展示了如何在存储过程中使用Sequence生成用户ID: ```plsql CREATE OR REPLACE PROCEDURE INSERT_USER ( p_username IN VARCHAR2, p_email IN VARCHAR2, p_user_id OUT NUMBER) AS BEGIN ...
本篇将重点介绍如何在使用JDeveloper这款强大的集成开发环境(IDE)时,结合Oracle的sequence和trigger来实现高效的数据操作。 首先,让我们理解一下sequence和trigger的概念。在Oracle中,sequence是一种自动递增...
在这个例子中,`emp_sequence`是一个名为“emp”的表生成主键所使用的序列。每次调用`NEXTVAL`方法时,`sequence`值将递增1,并且从1开始计数。如果不设置最大值,则默认为无上限。此外,还可以选择是否让`sequence`...
《Sequence to Sequence Learning with Neural Networks》是一篇由Ilya Sutskever, Oriol Vinyals和Quoc V. Le共同撰写的论文,三位作者都来自Google公司。这篇论文在自然语言处理领域有着重要的影响,特别是在序列...
sequence-diagram-js是一个基于JavaScript的开源库,用于生成序列图,其特色在于支持自定义颜色,使得设计出的序列图更具个性化和可读性。本篇文章将深入探讨sequence-diagram-js的核心功能,依赖库,以及如何使用...
本篇学习笔记将深入探讨SequenceFlow的概念、作用以及如何在流程设计中使用。 一、SequenceFlow简介 SequenceFlow 是 Activiti 流程模型中的概念,它表示了流程实例从一个活动(Activity)到另一个活动的流转。每个...
总之,了解并正确使用AX中的Number Sequence对于企业的数据管理和流程效率至关重要。它不仅简化了编号过程,还确保了数据的完整性和合规性。通过上述步骤,用户可以自定义并维护适合其业务需求的Number Sequence,...
在使用 SequenceDiagram-3.0.5 时,用户应当先了解序列图的基本概念和用法,然后根据需求选择合适的方式创建和编辑图。如果软件包含代码生成功能,要确保生成的代码符合项目的编码规范和设计模式。同时,定期检查...
以下是对Sequence创建和使用的详细说明: 1. **创建Sequence**: 使用`CREATE SEQUENCE`语句创建Sequence,例如: ```sql CREATE SEQUENCE S_Depart_sqs INCREMENT BY 1 START WITH 1 NOMAXVALUE NOCYCLE ...
Medoc sequence generator.zip三菱PLC编程案例源码资料编程控制器应用通讯通信例子程序实例Medoc sequence generator.zip三菱PLC编程案例源码资料编程控制器应用通讯通信例子程序实例Medoc sequence generator.zip...
**SequenceDiagram.zip** 文件包含的资源显然专注于在Windows .NET环境中使用序号图的实现。这个控件提供了一个动态的可视化平台,允许用户以UML标准的方式查看和理解对象间的交互。这种控件的亮点在于其**类似调试...
然后,我们使用一个PL/SQL块来遍历所有需要重置的Sequence,并根据表中的最大主键值来设置Sequence的起始值。 #### 1. 定义函数`func_getseq` ```sql CREATE OR REPLACE FUNCTION func_getseq (in_table VARCHAR2)...
在计算机科学中, Multibyte Character Sequence 指的是使用多个字节来表示一个字符的编码方式。这种编码方式主要用于表示非ASCII字符,例如中文字符。在Unicode标准中,每个字符可以使用多个字节来表示,例如UTF-8...
一旦定义了 SEQUENCE,可以使用 CURRVAL 和 NEXTVAL 来获取当前值和下一个值。CURRVAL 返回当前 SEQUENCE 的值,NEXTVAL 增加 SEQUENCE 的值,然后返回增加后的值。 例如,使用 S_S_DEPART SEQUENCE.insert 一个新...
在实际应用中,选择 Cycle 或 Reset 选项取决于具体的业务需求和系统限制。例如,如果系统需要序列号的唯一性非常高,可以选择 Reset 选项,而如果系统对序列号的唯一性没有特别限制,可以选择 Cycle 选项。...
可以通过`CREATE SEQUENCE`语句创建一个序列,并且能够通过`NEXTVAL`和`CURRVAL`来获取序列的下一个值以及当前值。 - **创建序列**: 使用`CREATE SEQUENCE`命令来定义序列。 ```sql CREATE SEQUENCE emp_sequence...
Sequence常用于为表中的某列自动生成唯一的主键值或者作为流水号使用。 #### 二、Sequence的创建与基本属性 ##### 创建Sequence的基本语法如下: ```sql CREATE SEQUENCE [start WITH n] -- 开始位置,默认递增...
机器学习之sequence to sequence learning。(Sequence Generation-----Hung-yi Lee 李宏毅.ppt)