[cvs] / jsr166 / src / main / java / util / concurrent / LinkedTransferQueue.java Repository:
ViewVC logotype

Diff of /jsr166/src/main/java/util/concurrent/LinkedTransferQueue.java

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 1.131, Thu Dec 29 23:08:16 2016 UTC revision 1.132, Sun Jan 1 23:17:58 2017 UTC
# Line 1440  Line 1440 
1440          restartFromHead: for (;;) {          restartFromHead: for (;;) {
1441              for (Node p = head, c = p, pred = null, q; p != null; ) {              for (Node p = head, c = p, pred = null, q; p != null; ) {
1442                  final Object item; boolean pAlive;                  final Object item; boolean pAlive;
1443                  if (pAlive = (((item = p.item) != null) && p.isData)) {                  if (pAlive = ((item = p.item) != null && p.isData)) {
1444                      if (o.equals(item) && p.tryMatchData()) {                      if (o.equals(item) && p.tryMatchData()) {
1445                          if ((q = p.next) == null) q = p;                          if ((q = p.next) == null) q = p;
1446                          if (c != q) tryCasSuccessor(pred, c, q);                          if (c != q) tryCasSuccessor(pred, c, q);
# Line 1477  Line 1477 
1477          restartFromHead: for (;;) {          restartFromHead: for (;;) {
1478              for (Node p = head, c = p, pred = null, q; p != null; ) {              for (Node p = head, c = p, pred = null, q; p != null; ) {
1479                  final Object item; final boolean pAlive;                  final Object item; final boolean pAlive;
1480                  if (pAlive = (((item = p.item) != null) && p.isData)) {                  if (pAlive = ((item = p.item) != null && p.isData)) {
1481                      if (o.equals(item))                      if (o.equals(item))
1482                          return true;                          return true;
1483                  }                  }
# Line 1590  Line 1590 
1590              // pred (or head if null) and p.              // pred (or head if null) and p.
1591              for (Node p = head, c = p, pred = null, q; p != null; p = q) {              for (Node p = head, c = p, pred = null, q; p != null; p = q) {
1592                  final Object item; boolean pAlive;                  final Object item; boolean pAlive;
1593                  if (pAlive = (((item = p.item) != null) && p.isData)) {                  if (pAlive = ((item = p.item) != null && p.isData)) {
1594                      if (filter.test((E) item)) {                      if (filter.test((E) item)) {
1595                          if (p.tryMatchData())                          if (p.tryMatchData())
1596                              removed = true;                              removed = true;
# Line 1626  Line 1626 
1626      void forEachFrom(Consumer<? super E> action, Node p) {      void forEachFrom(Consumer<? super E> action, Node p) {
1627          for (Node c = p, pred = null, q; p != null; ) {          for (Node c = p, pred = null, q; p != null; ) {
1628              final Object item; final boolean pAlive;              final Object item; final boolean pAlive;
1629              if (pAlive = (((item = p.item) != null) && p.isData))              if (pAlive = ((item = p.item) != null && p.isData))
1630                  action.accept((E) item);                  action.accept((E) item);
1631              else if (!p.isData && item == null)              else if (!p.isData && item == null)
1632                  break;                  break;

Legend:
Removed from v.1.131  
changed lines
  Added in v.1.132

Doug Lea
ViewVC Help
Powered by ViewVC 1.0.8