Package org.commoncrawl.async

Examples of org.commoncrawl.async.Timer

178
179
180
181
182
183
184
185
186
187
188
  @SuppressWarnings("unchecked")
  public <DataType extends RPCStruct,KeyType extends WritableComparable,ValueType extends Writable> BlockingQueryResult<KeyType,ValueType> blockingQueryRequest(final Query<DataType,KeyType,ValueType> queryObject,final ClientQueryInfo queryInfo) throws IOException {
   
    final LinkedBlockingQueue<BlockingQueryResult<KeyType,ValueType>> queue = new LinkedBlockingQueue<BlockingQueryResult<KeyType,ValueType>>(1);
   
    _host.getEventLoop().setTimer(new Timer(0,false,new Timer.Callback() {

      @Override
      public void timerFired(Timer timer) {
        try {
          queueClientQueryRequest(queryObject,queryInfo,new QueryCompletionCallback<DataType,KeyType, ValueType>() {
View Full Code Here
142
143
144
145
146
147
148
149
150
151
152
   
    Thread eventThread = (_ownsEventLoop) ? _eventLoop.getEventThread() : null;
   
    final Semaphore shutdownSemaphore = new Semaphore(0);
   
    _eventLoop.setTimer(new Timer(1,false,new Timer.Callback() {

      // shutdown within the context of the async thread ...
      public void timerFired(Timer timer) {
     
        try {
View Full Code Here
208
209
210
211
212
213
214
215
216
217
218
    int itemId = -1;
    synchronized (_queuedItems) {
      itemId = ++_lastItemId;
      _queuedItems.addLast(new S3DownloadItem(itemKey,itemId));
    }
    _eventLoop.setTimer(new Timer(1,false,new Timer.Callback() {

      public void timerFired(Timer timer) {
        // executes in the context of the event loop thread ...
        downloadNextItem();
      }
View Full Code Here
231
232
233
234
235
236
237
238
239
240
241
   
    synchronized (_queuedItems) {
      itemId = ++_lastItemId;
      _queuedItems.addLast(downloadItem);
    }
    _eventLoop.setTimer(new Timer(1,false,new Timer.Callback() {

      public void timerFired(Timer timer) {
        // executes in the context of the event loop thread ...
        downloadNextItem();
      }
View Full Code Here
130
131
132
133
134
135
136
137
138
139
140
      protected void done() {

        // completionQueue.add(this);
        // wake the event loop up ...
        // eventLoop.wakeup();
        eventLoop.setTimer(new Timer(0, false, new Timer.Callback() {

          @Override
          public void timerFired(Timer timer) {

            if (!isCancelled()) {
View Full Code Here
TOP

Related Classes of org.commoncrawl.async.Timer

  • org.commoncrawl.io.internal.NIODNSLocalResolver$DNSExecutorCompletionService$QueueingFuture
  • org.commoncrawl.query.Query
  • org.commoncrawl.query.QueryController
  • org.commoncrawl.query.QuerySlaveConnection
  • org.commoncrawl.query.QuerySlaveServer
  • org.commoncrawl.rpc.RPCChannel
  • org.commoncrawl.rpc.RPCServerChannel
  • org.commoncrawl.rpc.RPCTestServer
  • org.commoncrawl.server.AsyncWebServerRequest
  • org.commoncrawl.util.shared.S3Downloader
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.