我有一份ISIN列表,这是我唯一的信息来源.在Excel中,我可以捕获许多情况下需要的Bloomber股票代码,因为它指定了交易资产的交易所的代码.为此,我只需要在BDP() - 公式中添加"... Equity isin",其中"..."是ISIN的占位符.所以使用新的Rblpapi包(这是一个很棒的工具!)我可以尝试做同样的事情:
这是一个随机ISIN列表
isins = c("LU0942970442", "LU0997545750" ,"CH0019597530" , "CH0017142719" , "CH0131872431", "VGG0475N1087", "US46429B6974",
"LU0911032141" , "DE000A1JCWS9")
Run Code Online (Sandbox Code Playgroud)
在bdp公式中添加"公平"并调用"TICKER_AND_EXCH_CODE"
require(Rblpapi)
blpConnect()
portfolio_ticker = bdp(paste(c(isins),"equity"), "TICKER_AND_EXCH_CODE")
Run Code Online (Sandbox Code Playgroud)
但是没有指定一些代号.
> portfolio_ticker
TICKER_AND_EXCH_CODE
LU0942970442 equity XBAC SW
LU0997545750 equity AXESZHD LX
CH0019597530 equity
CH0017142719 equity
CH0131872431 equity
VGG0475N1087 equity ARIASII VI
US46429B6974 equity
LU0911032141 equity FCEUSMI LX
DE000A1JCWS9 equity CHOMCAR GR
Run Code Online (Sandbox Code Playgroud)
我的问题是:这是一个思考错误在我身边还是包装中的错误?
编辑:作为一个例子,它在Excel中看起来如何,这是相应的图片.
我有一个getHashMap返回的方法HashMap.我需要填充一个ConcurrentHashMap(in setConcurrentHashMap)HashMap.
有办法吗?
示例代码:
//getHashMap return a HashMap<String, String>
Map<String, String> myMap = getHashMap();
TestClass.getSingleton().setConcurrentHashMap(ConcurrentHashMap<String, String> concurrentHashMap)
Run Code Online (Sandbox Code Playgroud) 我试图使用以下目标在我的ant脚本中添加一些标记信息但是我得到一个错误(Result = -1)并且hg告诉我它不能识别命令:
<target name="-post-init">
<exec outputproperty="hg.tag" executable="hg">
<arg value="parents --template {latesttag}+{latesttagdistance}" />
</exec>
</target>
Run Code Online (Sandbox Code Playgroud)
如果我只包括value="parents"它工作正常.
如果我运行命令行hg parents --template {latesttag}+{latesttagdistance}它也可以正常工作.
关于我的语法错误的任何想法?
我有一个RSS Feed,其中我得到日期和新闻描述,我想添加以一种方式安排它,相同的日期包含当天的新闻.例如,
date 1 - my news 1
- my news 2
- my news 3
Run Code Online (Sandbox Code Playgroud) 我正在创建15个可调用任务,并提交它们:
List<Future<MyResult>> futures = new ArrayList<Future<MyResult>>();
List<MyResult> myResults = new ArrayList<MyResult>();
for(int i = 1; i <= 15; i++){
Callable<MyResult> task = new MyProcessor(//parameters);
Future<MyResult> future = executorService.submit(task);
futures.add(future);//used to iterate over to call get() to collect results in next for loop
}
Run Code Online (Sandbox Code Playgroud)
然后我收集了15个MyResult对象:
for(Future<MyResult> future : futures){
try {
MyResult myResult = future.get();
processorResults.add(myResult);
} catch (InterruptedException e) {
//...
} catch (ExecutionException e) {
//...
}
}
Run Code Online (Sandbox Code Playgroud)
问题是:不是从get()方法返回所有15个MyResult对象,我有时会得到少于15个对象.有时12有时10有时甚至更小,有时甚至15.
我的印象是,get()方法是一个阻塞调用,并且将等待所有15个线程返回相应的结果,但看起来我错过了其中一些并继续前进.我做错了什么?我没有收集结果/正确等待结果?当从任何MyProcessor任务抛出ERROR时会发生这种情况吗?
class cc extends Thread {
cc(String s) {
super(s);
}
}
class mainn {
public static void main (String args[]) {
cc t1 = new cc("first");
t1.start();
}
}
Run Code Online (Sandbox Code Playgroud)
问题:线程是否已经诞生
cc t1 = new cc("first");t1.start();?我创建了两个类:Initiator和Acceptor.我想从发起者向接受者发送消息,然后处理收到的消息.我无法发送消息.
这是我的initiator.java
SocketInitiator socketInitiator = null;
String fileName = "conf/intiator.cfg";
try {
SessionSettings initiatorSettings = new SessionSettings(new FileInputStream(fileName));
Application initiatorApplication = new Initiator();
FileStoreFactory fileStoreFactory = new FileStoreFactory(
initiatorSettings);
FileLogFactory fileLogFactory = new FileLogFactory(
initiatorSettings);
MessageFactory messageFactory = new DefaultMessageFactory();
socketInitiator = new SocketInitiator(initiatorApplication, fileStoreFactory, initiatorSettings, fileLogFactory, messageFactory);
socketInitiator.start();
Message msg = new Message();
msg.setString(1, "Hello this is test Message");
SessionID sessionId = (SessionID) socketInitiator.getSessions().get(0);
Session.lookupSession(sessionId).logon();
initiatorApplication.onLogon(sessionId);
initiatorApplication.toApp(msg, sessionId);
} catch (Exception e) {
e.printStackTrace();
}
Run Code Online (Sandbox Code Playgroud)
这是应用程序接口的overRide消息.
public void toApp(Message …Run Code Online (Sandbox Code Playgroud) public interface MemcachedAccessor {
void set(String key, Object value, int cacheTime, long timeout,
TimeUnit timeUnit);
Object get(String key);
}
Run Code Online (Sandbox Code Playgroud)
我有一个接口:MemcachedAccessor和一个实现:MemcachedAccessorImpl.
哪种名称风格更好?
MemcachedAccessor 和 MemcachedAccessorImpl
要么
MemcachedAccess 和 MemcachedAccessImpl
?
任何规则?
我知道eval锁定整个数据库,这对吞吐量不利 - 但是我有一个场景,必须隔离涉及多个文档的非常特定的事务.
因为该事务不经常发生并且相当快(对索引查询进行了一些更新),所以我正在考虑使用eval它来执行它.
他们应该注意到的任何陷阱(我看过几个eval =邪恶的帖子,但没有太多解释)?
如果数据库是副本集的一部分,它会有所不同吗?