Skip to content

Commit 2539027

Browse files
committed
AffinityThreadFactory should bind all thread created, not just the first one. #75
1 parent 4ff58df commit 2539027

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

affinity/src/main/java/net/openhft/affinity/AffinityThreadFactory.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,8 @@ public void run() {
6666
}
6767

6868
private synchronized AffinityLock acquireLockBasedOnLast() {
69-
AffinityLock al = lastAffinityLock == null ? AffinityLock.acquireLock() : lastAffinityLock.acquireLock(strategies);
69+
AffinityLock al = lastAffinityLock == null ? AffinityLock.acquireLock(false) : lastAffinityLock.acquireLock(strategies);
70+
al.bind();
7071
if (al.cpuId() >= 0)
7172
lastAffinityLock = al;
7273
return al;

0 commit comments

Comments
 (0)