com.amazonaws.services.simpleworkflow.flow.worker

## クラス ActivityTaskPoller

- java.lang.Object
- - com.amazonaws.services.simpleworkflow.flow.worker.SynchronousActivityTaskPoller
  - - com.amazonaws.services.simpleworkflow.flow.worker.ActivityTaskPoller

- すべての実装されたインタフェース:
    TaskPoller

      public class ActivityTaskPoller
      extends SynchronousActivityTaskPoller

- - ### フィールドの概要

    フィールド
    修飾子とタイプ | フィールドと説明
    --- | ---
    `protected java.util.concurrent.Semaphore` | `pollSemaphore`

  - ### コンストラクタの概要

    コンストラクタ
    コンストラクタと説明
    `ActivityTaskPoller(AmazonSimpleWorkflow service, java.lang.String domain, java.lang.String pollTaskList, ActivityImplementationFactory activityImplementationFactory, java.util.concurrent.ThreadPoolExecutor taskExecutorService)`

  - ### メソッドの概要

    メソッド
    修飾子とタイプ | メソッドと説明
    --- | ---
    `boolean` | `awaitTermination(long timeout, java.util.concurrent.TimeUnit unit)`
    `java.util.concurrent.ExecutorService` | `getTaskExecutorService()`
    `boolean` | `pollAndProcessSingleTask()` Poll for a activity task and execute correspondent implementation using provided executor service.
    `void` | `setTaskExecutorService(java.util.concurrent.ThreadPoolExecutor taskExecutorService)`
    `void` | `shutdown()`
    `void` | `shutdownNow()`

    - ### クラスから継承されたメソッド com.amazonaws.services.simpleworkflow.flow.worker.SynchronousActivityTaskPoller

      `checkRequiredProperty, execute, getActivityImplementationFactory, getDomain, getIdentity, getPollTaskList, getReportCompletionRetryParameters, getReportFailureRetryParameters, getService, getTaskListToPoll, poll, respondActivityTaskCanceled, respondActivityTaskCanceledWithRetry, respondActivityTaskCompleted, respondActivityTaskCompletedWithRetry, respondActivityTaskFailed, respondActivityTaskFailedWithRetry, setActivityImplementationFactory, setDomain, setIdentity, setReportCompletionRetryParameters, setReportFailureRetryParameters, setService, setTaskListToPoll`

    - ### クラスから継承されたメソッド java.lang.Object

      `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

- - ### フィールドの詳細

    - #### pollSemaphore

          protected java.util.concurrent.Semaphore pollSemaphore

  - ### コンストラクタの詳細

    - #### ActivityTaskPoller

          public ActivityTaskPoller(AmazonSimpleWorkflow service,
                            java.lang.String domain,
                            java.lang.String pollTaskList,
                            ActivityImplementationFactory activityImplementationFactory,
                            java.util.concurrent.ThreadPoolExecutor taskExecutorService)

  - ### メソッドの詳細

    - #### getTaskExecutorService

          public java.util.concurrent.ExecutorService getTaskExecutorService()

    - #### setTaskExecutorService

          public void setTaskExecutorService(java.util.concurrent.ThreadPoolExecutor taskExecutorService)

    - #### pollAndProcessSingleTask

          public boolean pollAndProcessSingleTask()
                                           throws java.lang.Exception

      Poll for a activity task and execute correspondent implementation using provided executor service.
      定義:
        `pollAndProcessSingleTask` インタフェース内 `TaskPoller`
      オーバーライド:
        `pollAndProcessSingleTask` クラス内 `SynchronousActivityTaskPoller`
      戻り値:
        true if task was polled and decided upon, false if poll timed out
      例外:
        `java.lang.Exception`

    - #### shutdown

          public void shutdown()

      定義:
        `shutdown` インタフェース内 `TaskPoller`
      オーバーライド:
        `shutdown` クラス内 `SynchronousActivityTaskPoller`

    - #### shutdownNow

          public void shutdownNow()

      定義:
        `shutdownNow` インタフェース内 `TaskPoller`
      オーバーライド:
        `shutdownNow` クラス内 `SynchronousActivityTaskPoller`

    - #### awaitTermination

          public boolean awaitTermination(long timeout,
                                 java.util.concurrent.TimeUnit unit)
                                   throws java.lang.InterruptedException

      定義:
        `awaitTermination` インタフェース内 `TaskPoller`
      オーバーライド:
        `awaitTermination` クラス内 `SynchronousActivityTaskPoller`
      例外:
        `java.lang.InterruptedException`