SingleThreadStrategy extends AbstractThreadStrategy
Table of Contents
Constants
- THREAD_LOCKED = -2
- THREAD_NEEDED = 1
- THREAD_UNAVAILABLE = -1
- THREADS_COUNT = 1
Methods
- checkThreads() : int|null
- Check threads is available and not need to insert
- fillThreads() : void
- Insert new posting threads with ignore of conflicts
- finalize() : mixed
- Finalize thread activity
- getRecipients() : Result
- getThreadId() : int
- get current thread id
- hasUnprocessedThreads() : bool
- checking that all threads are completed
- isProcessLimited() : bool
- Returns true if sending not available
- lastThreadId() : int
- get last thread number
- lockThread() : int|null
- lock thread for duplicate select
- setPostingId() : TenThreadsStrategy
- updateStatus() : bool
- update status with expire date
Constants
THREAD_LOCKED
public
mixed
THREAD_LOCKED
= -2
THREAD_NEEDED
public
mixed
THREAD_NEEDED
= 1
THREAD_UNAVAILABLE
public
mixed
THREAD_UNAVAILABLE
= -1
THREADS_COUNT
public
mixed
THREADS_COUNT
= 1
Methods
checkThreads()
Check threads is available and not need to insert
public
checkThreads() : int|null
Tags
Return values
int|nullfillThreads()
Insert new posting threads with ignore of conflicts
public
fillThreads() : void
finalize()
Finalize thread activity
public
finalize() : mixed
getRecipients()
public
getRecipients(mixed $limit) : Result
Parameters
- $limit : mixed
Tags
Return values
ResultgetThreadId()
get current thread id
public
getThreadId() : int
Return values
inthasUnprocessedThreads()
checking that all threads are completed
public
hasUnprocessedThreads() : bool
Return values
boolisProcessLimited()
Returns true if sending not available
public
isProcessLimited() : bool
Return values
boollastThreadId()
get last thread number
public
lastThreadId() : int
Return values
intlockThread()
lock thread for duplicate select
public
lockThread() : int|null
Tags
Return values
int|nullsetPostingId()
public
setPostingId(int $postingId) : TenThreadsStrategy
Parameters
- $postingId : int
Return values
TenThreadsStrategyupdateStatus()
update status with expire date
public
updateStatus(mixed $status) : bool
Parameters
- $status : mixed